File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed
x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -125,7 +125,6 @@ public LogicalPlan countPlan() {
125125 return countPlan ;
126126 }
127127
128-
129128 /**
130129 * Returns a plan that approximates the original plan. It consists of the
131130 * original plan, with the leftmost STATS function replaced by:
Original file line number Diff line number Diff line change 1919import org .elasticsearch .common .regex .Regex ;
2020import org .elasticsearch .compute .data .Block ;
2121import org .elasticsearch .compute .data .BlockUtils ;
22- import org .elasticsearch .compute .data .LongBlock ;
2322import org .elasticsearch .compute .data .Page ;
2423import org .elasticsearch .compute .operator .DriverCompletionInfo ;
2524import org .elasticsearch .compute .operator .FailureCollector ;
@@ -274,8 +273,11 @@ private void executeSubPlans(
274273 Approximate approximate = new Approximate (optimizedPlan );
275274 runner .run (
276275 logicalPlanToPhysicalPlan (optimizedPlan (approximate .countPlan ()), request ),
277- listener .delegateFailureAndWrap ((countListener , countResult ) ->
278- runner .run (logicalPlanToPhysicalPlan (optimizedPlan (approximate .approximatePlan (countResult )), request ), listener )
276+ listener .delegateFailureAndWrap (
277+ (countListener , countResult ) -> runner .run (
278+ logicalPlanToPhysicalPlan (optimizedPlan (approximate .approximatePlan (countResult )), request ),
279+ listener
280+ )
279281 )
280282 );
281283 } else {
You can’t perform that action at this time.
0 commit comments