还是需要聚合
This commit is contained in:
parent
592a5016d8
commit
dc5fb1a487
|
@ -34,10 +34,10 @@ namespace ShardingCore.Sharding.MergeEngines.ShardingExecutors
|
||||||
if (results.IsEmpty())
|
if (results.IsEmpty())
|
||||||
throw new ShardingCoreException("sharding execute result empty");
|
throw new ShardingCoreException("sharding execute result empty");
|
||||||
//不需要merge
|
//不需要merge
|
||||||
if (results.Count == 1)
|
//if (results.Count == 1)
|
||||||
{
|
//{
|
||||||
return results[0];
|
// return results[0];
|
||||||
}
|
//}
|
||||||
var streamMerge = executor.GetShardingMerger().StreamMerge(results);
|
var streamMerge = executor.GetShardingMerger().StreamMerge(results);
|
||||||
return streamMerge;
|
return streamMerge;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue