File tree Expand file tree Collapse file tree 1 file changed +6
-12
lines changed
ydb/core/kqp/executer_actor Expand file tree Collapse file tree 1 file changed +6
-12
lines changed Original file line number Diff line number Diff line change @@ -1067,18 +1067,12 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
10671067 return !lhs.Ranges ->GetRightBorder ().first ->GetCells ().empty ();
10681068 }
10691069
1070- const size_t size = std::min (lhs.Ranges ->GetRightBorder ().first ->GetCells ().size (), rhs.Ranges ->GetRightBorder ().first ->GetCells ().size ());
1071- YQL_ENSURE (size <= keyTypes.size ());
1072- int result = CompareTypedCellVectors (
1073- lhs.Ranges ->GetRightBorder ().first ->GetCells ().data (),
1074- rhs.Ranges ->GetRightBorder ().first ->GetCells ().data (),
1075- keyTypes.data (), size);
1076-
1077- if (result != 0 ) {
1078- return result < 0 ;
1079- }
1080-
1081- return lhs.Ranges ->GetRightBorder ().first ->GetCells ().size () > rhs.Ranges ->GetRightBorder ().first ->GetCells ().size ();
1070+ return CompareBorders<false , false >(
1071+ lhs.Ranges ->GetRightBorder ().first ->GetCells (),
1072+ rhs.Ranges ->GetRightBorder ().first ->GetCells (),
1073+ lhs.Ranges ->GetRightBorder ().second ,
1074+ rhs.Ranges ->GetRightBorder ().second ,
1075+ keyTypes) < 0 ;
10821076 });
10831077
10841078 // One shard (ranges set) can be assigned only to one task. Otherwise, we can break some optimizations like removing unnecessary shuffle.
You can’t perform that action at this time.
0 commit comments