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.Blocking aggregation operator.AsyncOperator<Fetched>AsyncOperatorperforms an external computation specified inAsyncOperator.performAsync(Page, ActionListener).Builder for bytes arrays that checks its size against aCircuitBreaker.Find spikes, dips and change point in a list of values.Factory forColumnLoadOperator.A base class that loads in and works across all input pages for an operatorOperator 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 a tree of 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.An operator that limits the number of rows emitted per group.Encodes the values at a given position across multiple blocks into a singleBytesRefcomposite key.Builder forHashAggregationOperator.Is thisOperatorblocked?A shared limiter used by multiple drivers to collect hits in parallel without exceeding the output limit.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.This operator generates 0 values for all buckets that are not present in the input data for a sparkline graph.A specialized version ofHashAggregationOperatorthat aggregates time-series aggregations from time-series sources.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.