Skip to content

Commit d47ec75

Browse files
idegtiarenkoafoucret
authored andcommitted
Simplify esql session (elastic#131925)
1 parent 38fa394 commit d47ec75

File tree

1 file changed

+1
-5
lines changed
  • x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session

1 file changed

+1
-5
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlSession.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -387,7 +387,7 @@ public void analyzedPlan(
387387
var listener = SubscribableListener.<EnrichResolution>newForked(
388388
l -> enrichPolicyResolver.resolvePolicies(unresolvedPolicies, executionInfo, l)
389389
)
390-
.<PreAnalysisResult>andThen((l, enrichResolution) -> resolveFieldNames(parsed, enrichResolution, l))
390+
.<PreAnalysisResult>andThenApply(enrichResolution -> FieldNameUtils.resolveFieldNames(parsed, enrichResolution))
391391
.<PreAnalysisResult>andThen((l, preAnalysisResult) -> resolveInferences(parsed, preAnalysisResult, l));
392392
// first resolve the lookup indices, then the main indices
393393
for (var index : preAnalysis.lookupIndices) {
@@ -741,10 +741,6 @@ private static void analyzeAndMaybeRetry(
741741
logicalPlanListener.onResponse(plan);
742742
}
743743

744-
private static void resolveFieldNames(LogicalPlan parsed, EnrichResolution enrichResolution, ActionListener<PreAnalysisResult> l) {
745-
ActionListener.completeWith(l, () -> FieldNameUtils.resolveFieldNames(parsed, enrichResolution));
746-
}
747-
748744
private void resolveInferences(LogicalPlan plan, PreAnalysisResult preAnalysisResult, ActionListener<PreAnalysisResult> l) {
749745
inferenceService.inferenceResolver().resolveInferenceIds(plan, l.map(preAnalysisResult::withInferenceResolution));
750746
}

0 commit comments

Comments
 (0)