Package org.elasticsearch.xpack.esql.plan.logical
package org.elasticsearch.xpack.esql.plan.logical
-
ClassDescriptionPlan that detects change points in a list of values.CompoundOutputEval<T extends CompoundOutputEval<T>>Base class for logical plan nodes that make a single evaluation on a single input expression and produce multiple output columns.Source representing an Elasticsearch index.Mark nodes that execute only in a specific way, either on the coordinator or on a remote node.Executes on the coordinator only.Executes on the remote nodes only (note that may include coordinator, but not on the aggregation stage).Logical plan node for external data source relations (e.g., Iceberg table, Parquet file).A
Filteris a type of Plan that performs filtering of results.A Fork is a n-aryPlanwhere each child is a sub plan, e.g.Enriches the stream of data with the results of running aSTATS.Retains at most N rows per group defined by one or more grouping key expressions.A LogicalPlan is what (not the "how") a user told us they want to do.Order is important in the enum; any values should be added at the end.Looks up values from the associatedtables.AMetricsInfois a plan node that returns one row per metric with metadata.Logical plan for the MMR command.ASubquerythat carries the view name it was resolved from.Logical plan node representing a parameterized lookup query source.ALogicalPlanthat cannot be run only on the data nodes, resp.Remove, duplicate or rename columns.The logical plan for theREGISTERED_DOMAINcommand.Aggregate, which upon execution is either: sampled with thesampleProbabilityfor fast execution; or replaced by an exact aggregate if theoriginalAggregatescan be pushed down to Lucene.This interface is intended to check redundancy of a previous SORT.This is a marker interface for commands that maintain the sort order of their input.Contains all varieties of source commands (FROM, TS, PROMQL, ...) and their associated index mode.This interface marks commands which do not add or remove rows and aren't sensitive to the exact order of the rows.Interface signaling to the planner that the declaring plan should be replaced with the surrogate plan.An extension ofAggregateto perform time-series aggregation per time-series, such as rate or _over_time.Logical plan node forSORT order1, order2 | LIMIT N BY grouping1, grouping2, ....ATsInfois a plan node that returns one row per time series with metadata.AUnaryPlanis aLogicalPlanwith exactly one child, for example,WHERE xin a SQL statement is anUnaryPlan.Represents an unresolved external data source reference (Iceberg table or Parquet file).The logical plan for theURI_PARTScommand.The logical plan for theUSER_AGENTcommand.AUnionAllproduced by view resolution, as opposed to user-written subqueries.