Module org.elasticsearch.compute
Package org.elasticsearch.compute.operator
package org.elasticsearch.compute.operator
-
ClassDescriptionAbstract superclass for operators that accept a single page, modify it, and then return it.Maps a single
Pageinto zero or more resulting pages.Aggregates inputPages into a single output row.AsyncOperator<Fetched>AsyncOperatorperforms an external computation specified inAsyncOperator.performAsync(Page, ActionListener).Builder for bytes arrays that checks its size against aCircuitBreaker.Implemented byOperator.Statussubclasses that capture per-file source-metadata contributions during data-node execution.Find spikes, dips and change points in a list of values.Factory forColumnLoadOperator.A base class that loads in and works across all input pages for an operatorSpecializes a class at runtime that extends a given evaluator base class and supplies specified constants in a way HotSpot's C2 compiler treats as JIT-time constants.Operator that filters rows to keep only the first occurrence of each distinct key value.Information returned when one of moreDrivers is completed.A driver-local context that is shared across operators.A snapshot of the driver context.Indicates the behavior Evaluators of this context should use for reporting warningsAn exception indicates that a compute should be terminated early as the downstream pipeline has enough or no long requires more data.Profile results from a singleDriver.Run a set of drivers to completion.Records of the times the driver has slept.A record of a time the driver slept.Task.Statusreported from aDriverto be reported by the tasks api.ADriverRunnerthat executesDriverwith a child task so that we can retrieve the progress with the Task API.Evaluates functions for every position in the block, resulting in a new block which is appended to the page.FailureCollectoris responsible for collecting exceptions that occur in the compute engine.Filters rows from inputPages.An operator that limits the number of rows emitted per group.Encodes the values at a given position across multiple blocks into a single composite key.Aggregates inputPages into many output rows, grouping by some values.Builder forHashAggregationOperator.Compute-side configuration handed straight toHighlightOperator.Appends one highlighted keyword column per ON field to the input page.Is thisOperatorblocked?A shared limiter used by multiple drivers to collect hits in parallel without exceeding the output limit.Limits the number of output rows.Operator for the ESQLMETRICS_INFOcommand.Factory for INITIAL mode (data nodes): extracts metric metadata from shards.Factory for FINAL mode (coordinator): merges 6-column pages from multiple data nodes.Looks up metric field metadata on demand.ES|QL Operator for performing MMR result diversification MMR performs result diversification on incoming results using maximum marginal relevance.Factor creation for the MMR Operator"Expands" multivalued blocks by duplicating all the other columns for each value.Operator is low-level building block that consumes, transforms and produces data.A factory for creating intermediate operators.Status of anOperatorto be returned by the tasks API.Status of anOperator.Sink operator that calls a given listener for each page received.Interface for DriverContext implementations that provide a collectedPages list.Sink operator that's useful for passing off pages to aConsumer.Wrapper aroundCloseableIteratorofPages that stops yielding pages once a cumulative row budget is exhausted.Profile information for plan optimization phases.A helper class that can be used to collect and merge response headers from multiple child requests.Factory forRowInTableLookupOperator.Evaluates scores for a ExpressionScorer.Evaluates the score of an expression onePageat a time.A Factory for creating ExpressionScorers.A "side channel" for theOperators running on one node.SideChannel.Supplier<T extends SideChannel>Builds theSideChannelon first use and returns a shared reference on the next use.A sink operator - accepts input, produces no output.A factory for creating sink operators.A source operator - produces output, accepts no input.A factory for creating source operators.Fills in zero-valued buckets for data produced by the last sparkline aggregation phase and stops the@timestampcolumns.A specialized version ofHashAggregationOperatorthat aggregates time-series aggregations from time-series sources.Collapses expanded time-series rows into one multi-valued row per output series.Operator for the ESQLTS_INFOcommand.Factory for INITIAL mode (data nodes).Factory for FINAL mode (coordinator): merges 7-column pages from multiple data nodes.Utilities to collect warnings for running an executor.Interface for providing source location information for warnings.