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.Factory forColumnLoadOperator.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.Status of anOperator.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.A Factory for creating ExpressionEvaluators.FailureCollectoris responsible for collecting exceptions that occur in the compute engine.Is thisOperatorblocked?A shared limiter used by multiple drivers to collect hits in parallel without exceeding the output limit."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.UnlikeHashAggregationOperator, this hash operator also extracts values or ordinals of the input documents.Sink operator that calls a given listener for each page received.Sink operator that's useful for passing off pages to aConsumer.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 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 class provides operator factories for time-series aggregations.Utilities to collect warnings for running an executor.