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() {
125
125
return countPlan ;
126
126
}
127
127
128
-
129
128
/**
130
129
* Returns a plan that approximates the original plan. It consists of the
131
130
* original plan, with the leftmost STATS function replaced by:
Original file line number Diff line number Diff line change 19
19
import org .elasticsearch .common .regex .Regex ;
20
20
import org .elasticsearch .compute .data .Block ;
21
21
import org .elasticsearch .compute .data .BlockUtils ;
22
- import org .elasticsearch .compute .data .LongBlock ;
23
22
import org .elasticsearch .compute .data .Page ;
24
23
import org .elasticsearch .compute .operator .DriverCompletionInfo ;
25
24
import org .elasticsearch .compute .operator .FailureCollector ;
@@ -274,8 +273,11 @@ private void executeSubPlans(
274
273
Approximate approximate = new Approximate (optimizedPlan );
275
274
runner .run (
276
275
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
+ )
279
281
)
280
282
);
281
283
} else {
You can’t perform that action at this time.
0 commit comments