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 interfaceContext 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) final Operator.OperatorFactoryordinalGroupingOperatorFactory(LocalExecutionPlanner.PhysicalOperation source, AggregateExec aggregateExec, List<GroupingAggregator.Factory> aggregatorFactories, Attribute attrSource, ElementType groupElementType, LocalExecutionPlanner.LocalExecutionPlannerContext context) Build a grouping operator that operates on ordinals if possible.querySupplier(QueryBuilder builder) sourcePhysicalOperation(EsQueryExec esQueryExec, 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) -
countSource
public LuceneCountOperator.Factory countSource(LocalExecutionPlanner.LocalExecutionPlannerContext context, QueryBuilder queryBuilder, Expression limit) Build aSourceOperator.SourceOperatorFactorythat counts documents in the search index. -
ordinalGroupingOperatorFactory
public final Operator.OperatorFactory ordinalGroupingOperatorFactory(LocalExecutionPlanner.PhysicalOperation source, AggregateExec aggregateExec, List<GroupingAggregator.Factory> aggregatorFactories, Attribute attrSource, ElementType groupElementType, LocalExecutionPlanner.LocalExecutionPlannerContext context) Description copied from class:AbstractPhysicalOperationProvidersBuild a grouping operator that operates on ordinals if possible.- Specified by:
ordinalGroupingOperatorFactoryin classAbstractPhysicalOperationProviders
-