Class EsQueryExec
java.lang.Object
org.elasticsearch.xpack.esql.core.tree.Node<PhysicalPlan>
org.elasticsearch.xpack.esql.plan.QueryPlan<PhysicalPlan>
org.elasticsearch.xpack.esql.plan.physical.PhysicalPlan
org.elasticsearch.xpack.esql.plan.physical.LeafExec
org.elasticsearch.xpack.esql.plan.physical.EsQueryExec
- All Implemented Interfaces:
NamedWriteable,Writeable,EstimatesRowSize
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic enumstatic final recordstatic final recordstatic enumstatic final recordstatic interfaceNested classes/interfaces inherited from interface org.elasticsearch.xpack.esql.plan.physical.EstimatesRowSize
EstimatesRowSize.StateNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final EsFieldstatic final NamedWriteableRegistry.Entrystatic final List<EsQueryExec.Sort> -
Constructor Summary
ConstructorsConstructorDescriptionEsQueryExec(Source source, String indexPattern, IndexMode indexMode, Map<String, IndexMode> indexNameWithModes, List<Attribute> attributes, QueryBuilder query) EsQueryExec(Source source, String indexPattern, IndexMode indexMode, Map<String, IndexMode> indexNameWithModes, List<Attribute> attrs, QueryBuilder query, Expression limit, List<EsQueryExec.Sort> sorts, Integer estimatedRowSize) -
Method Summary
Modifier and TypeMethodDescriptionattrs()booleanbooleanEstimate of the number of bytes that'll be loaded per position before the stream of pages is consumed.Estimate the number of bytes that'll be loaded per position before the stream of pages is consumed.inthashCode()booleanprotected NodeInfo<EsQueryExec> info()static booleanisSourceAttribute(Attribute attr) limit()output()The ordered list of attributes (i.e.query()sorts()withLimit(Expression limit) withQuery(QueryBuilder query) withSorts(List<EsQueryExec.Sort> sorts) voidwriteTo(StreamOutput out) Methods inherited from class org.elasticsearch.xpack.esql.plan.physical.LeafExec
computeReferences, replaceChildrenMethods inherited from class org.elasticsearch.xpack.esql.plan.QueryPlan
computeExpressions, expressions, forEachExpression, forEachExpression, forEachExpressionDown, forEachExpressionUp, inputSet, outputSet, references, transformExpressionsDown, transformExpressionsDown, transformExpressionsOnly, transformExpressionsOnly, transformExpressionsOnlyUp, transformExpressionsUp, transformExpressionsUpMethods inherited from class org.elasticsearch.xpack.esql.core.tree.Node
anyMatch, children, collect, collectFirstChildren, collectLeaves, doCollectFirst, forEachDown, forEachDown, forEachDownMayReturnEarly, forEachProperty, forEachPropertyDown, forEachPropertyOnly, forEachPropertyUp, forEachUp, forEachUp, nodeName, nodeProperties, propertiesToString, replaceChildrenSameSize, source, sourceLocation, sourceText, toString, transformChildren, transformDown, transformDown, transformDown, transformNodeProps, transformPropertiesDown, transformPropertiesOnly, transformPropertiesUp, transformUp, transformUp, transformUp
-
Field Details
-
ENTRY
-
DOC_ID_FIELD
-
NO_SORTS
-
-
Constructor Details
-
EsQueryExec
-
EsQueryExec
public EsQueryExec(Source source, String indexPattern, IndexMode indexMode, Map<String, IndexMode> indexNameWithModes, List<Attribute> attrs, QueryBuilder query, Expression limit, List<EsQueryExec.Sort> sorts, Integer estimatedRowSize)
-
-
Method Details
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable
-
isSourceAttribute
-
hasScoring
public boolean hasScoring() -
info
- Specified by:
infoin classNode<PhysicalPlan>
-
indexPattern
-
indexMode
-
indexNameWithModes
-
query
-
output
Description copied from class:QueryPlanThe ordered list of attributes (i.e. columns) this plan produces when executed. Must be called only on resolved plans, otherwise may throw an exception or return wrong results.- Specified by:
outputin classQueryPlan<PhysicalPlan>
-
limit
-
sorts
-
attrs
-
estimatedRowSize
Estimate of the number of bytes that'll be loaded per position before the stream of pages is consumed. -
estimateRowSize
Description copied from interface:EstimatesRowSizeEstimate the number of bytes that'll be loaded per position before the stream of pages is consumed.- Specified by:
estimateRowSizein interfaceEstimatesRowSize- Returns:
-
withLimit
-
canPushSorts
public boolean canPushSorts() -
withSorts
-
withQuery
-
hashCode
public int hashCode()- Specified by:
hashCodein classPhysicalPlan
-
equals
- Specified by:
equalsin classPhysicalPlan
-
nodeString
- Overrides:
nodeStringin classNode<PhysicalPlan>
-