Class EsPhysicalOperationProviders
java.lang.Object
org.elasticsearch.xpack.esql.planner.AbstractPhysicalOperationProviders
org.elasticsearch.xpack.esql.planner.EsPhysicalOperationProviders
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classContext of each shard we're operating against. -
Constructor Summary
ConstructorsConstructorDescriptionEsPhysicalOperationProviders(FoldContext foldContext, List<EsPhysicalOperationProviders.ShardContext> shardContexts, AnalysisRegistry analysisRegistry, PhysicalSettings physicalSettings) -
Method Summary
Modifier and TypeMethodDescriptioncountSource(LocalExecutionPlanner.LocalExecutionPlannerContext context, QueryBuilder queryBuilder, Expression limit) Build aSourceOperator.SourceOperatorFactorythat counts documents in the search index.fieldExtractPhysicalOperation(FieldExtractExec fieldExtractExec, LocalExecutionPlanner.PhysicalOperation source) querySupplier(QueryBuilder builder) sourcePhysicalOperation(EsQueryExec esQueryExec, LocalExecutionPlanner.LocalExecutionPlannerContext context) timeSeriesAggregatorOperatorFactory(TimeSeriesAggregateExec ts, AggregatorMode aggregatorMode, List<GroupingAggregator.Factory> aggregatorFactories, List<BlockHash.GroupSpec> groupSpecs, LocalExecutionPlanner.LocalExecutionPlannerContext context) timeSeriesSourceOperation(TimeSeriesSourceExec ts, LocalExecutionPlanner.LocalExecutionPlannerContext context) Methods inherited from class org.elasticsearch.xpack.esql.planner.AbstractPhysicalOperationProviders
groupingPhysicalOperation, intermediateAttributes
-
Constructor Details
-
EsPhysicalOperationProviders
public EsPhysicalOperationProviders(FoldContext foldContext, List<EsPhysicalOperationProviders.ShardContext> shardContexts, AnalysisRegistry analysisRegistry, PhysicalSettings physicalSettings)
-
-
Method Details
-
fieldExtractPhysicalOperation
public final LocalExecutionPlanner.PhysicalOperation fieldExtractPhysicalOperation(FieldExtractExec fieldExtractExec, LocalExecutionPlanner.PhysicalOperation source) -
querySupplier
public Function<ShardContext,List<LuceneSliceQueue.QueryAndTags>> querySupplier(QueryBuilder builder) -
sourcePhysicalOperation
public final LocalExecutionPlanner.PhysicalOperation sourcePhysicalOperation(EsQueryExec esQueryExec, LocalExecutionPlanner.LocalExecutionPlannerContext context) -
timeSeriesSourceOperation
public LocalExecutionPlanner.PhysicalOperation timeSeriesSourceOperation(TimeSeriesSourceExec ts, LocalExecutionPlanner.LocalExecutionPlannerContext context) -
countSource
public LuceneCountOperator.Factory countSource(LocalExecutionPlanner.LocalExecutionPlannerContext context, QueryBuilder queryBuilder, Expression limit) Build aSourceOperator.SourceOperatorFactorythat counts documents in the search index. -
timeSeriesAggregatorOperatorFactory
public Operator.OperatorFactory timeSeriesAggregatorOperatorFactory(TimeSeriesAggregateExec ts, AggregatorMode aggregatorMode, List<GroupingAggregator.Factory> aggregatorFactories, List<BlockHash.GroupSpec> groupSpecs, LocalExecutionPlanner.LocalExecutionPlannerContext context) - Specified by:
timeSeriesAggregatorOperatorFactoryin classAbstractPhysicalOperationProviders
-