All Classes and Interfaces
Class
Description
Base class for array states that track which group ids have been set.
Base class that extends
AbstractArrayState to add failure tracking.Abstract superclass for operators that accept a single page, modify it, and then return it.
Maps a single
Page into zero or more resulting pages.Blocking aggregation operator.
A non-grouped aggregation.
Builds aggregation implementations, closing over any state required to do so.
RowInTableLookup that models an increasing sequence of integers.AsyncOperator performs an external computation specified in
AsyncOperator.performAsync(Page, ActionListener).Decodes values encoded by
BatchEncoder.Checks if an offset is
null.A Block is a columnar representation of homogenous data.
Builds
Blocks.How are multivalued fields ordered?
Some operators can enable its optimization when mv_values are sorted ascending or de-duplicated.
Specialized hash table implementations that map rows to a set
of bucket IDs to which they belong to implement
GROUP BY expressions.Stream for reading
Blocks.Returned by
BlockUtils.toJavaObject(org.elasticsearch.compute.data.Block, int) for "doc" type blocks.Block implementation that stores values in a
BooleanBigArrayVector.Vector implementation that defers to an enclosed
BitArray.Block that stores boolean values.
Builder for
BooleanBlockAggregates the top N boolean values per bucket.
Vector that stores boolean values.
A builder that grows as needed.
A builder that never grows.
Block view of a
BooleanVector.Builder for
BooleanVectors that never grows.Builder for bytes arrays that checks its size against a
CircuitBreaker.Aggregator state for an array of BytesRefs.
Block that stores BytesRef values.
Builder for
BytesRefBlockAggregates the top N variable length
BytesRef values per bucket.Vector that stores BytesRef values.
A builder that grows as needed.
Block view of a
BytesRefVector.BlockHash implementation for
Categorize grouping function.BlockHash implementation for
Categorize grouping function as first
grouping expression, followed by one or mode other grouping expressions.Factory for
ColumnLoadOperator.This vector is never instantiated.
A component capable of describing itself.
Vector where each entry references a lucene document.Block implementation that stores values in a
DoubleBigArrayVector.Vector implementation that defers to an enclosed
DoubleArray.Block that stores double values.
Builder for
DoubleBlockAggregates the top N double values per bucket.
Vector that stores double values.
A builder that grows as needed.
A builder that never grows.
Block view of a
DoubleVector.Builder for
DoubleVectors that never grows.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 warnings
An 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 single
Driver.Run a set of drivers to completion.
Records of the times the driver has slept.
A record of a time the driver slept.
Task.Status reported from a Driver to be reported by the tasks api.Status of an
Operator.A
DriverRunner that executes Driver with a child task so that we can retrieve the progress with the Task API.RowInTableLookup for an empty table.Lookup document IDs for the input queries.
Similar to
RefCountingListener,
but prefers non-task-cancelled exceptions over task-cancelled ones as they are more useful for diagnosing issues.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.
ExchangeService is responsible for exchanging pages between exchange sinks and sources on the same or different nodes.Sink for exchanging data
An
ExchangeSinkHandler receives pages and status from its ExchangeSinks, which are created using
ExchangeSinkHandler.createExchangeSink(Runnable)} method.Sink operator implementation that pushes data to an
ExchangeSinkSource for exchanging data
An
ExchangeSourceHandler asynchronously fetches pages and status from multiple RemoteSinks
and feeds them to its ExchangeSource, which are created using the ExchangeSourceHandler.createExchangeSource()) method.Source operator implementation that retrieves data from an
ExchangeSourceFailureCollector is responsible for collecting exceptions that occur in the compute engine.A
AggregatorFunctionSupplier that wraps another, filtering which positions
are supplied to the aggregator.Block implementation that stores values in a
FloatBigArrayVector.Vector implementation that defers to an enclosed
FloatArray.Block that stores float values.
Builder for
FloatBlockAggregates the top N float values per bucket.
Vector that stores float values.
A builder that grows as needed.
A builder that never grows.
Block view of a
FloatVector.Builder for
FloatVectors that never grows.Applies some grouping function like
min or avg to many values,
grouped into buckets.Consume group ids to cause the
GroupingAggregatorFunction
to group values at a particular position into a particular group.Block implementation that stores values in a
IntBigArrayVector.Vector implementation that defers to an enclosed
IntArray.Block that stores int values.
Builder for
IntBlockAggregates the top N int values per bucket.
Intermediate aggregation state descriptor.
Vector that stores int values.
A builder that grows as needed.
A builder that never grows.
Block view of a
IntVector.Builder for
IntVectors that never grows.Aggregator state for an array of IPs.
Aggregates the top N IP values per bucket.
Is this
Operator blocked?A shared limiter used by multiple drivers to collect hits in parallel without exceeding the output limit.
Requesting and returning memory from a
CircuitBreaker can be costly due to the involvement of read/write
on one or several atomic longs.Block implementation that stores values in a
LongBigArrayVector.Vector implementation that defers to an enclosed
LongArray.Block that stores long values.
Builder for
LongBlockAggregates the top N long values per bucket.
Vector that stores long values.
A builder that grows as needed.
A builder that never grows.
Block view of a
LongVector.Builder for
LongVectors that never grows.Source operator that incrementally counts the results in Lucene searches
Returns always one entry that mimics the Count aggregation internal state:
1.
Factory that generates an operator that finds the max value of a field using the
LuceneMinMaxOperator.Factory that generates an operator that finds the min value of a field using the
LuceneMinMaxOperator.Base class for evaluating a Lucene query at the compute engine and providing a Block as a result.
EvalOperator.ExpressionEvaluator to run a Lucene Query during
the compute engine's normal execution, yielding matches/does not match into
a BooleanVector.ScoreOperator.ExpressionScorer to run a Lucene Query during
the compute engine's normal execution, yielding the corresponding scores into
a DoubleVector.Holds a list of multiple partial Lucene segments
Shared Lucene slices between Lucene operators.
Source operator that incrementally runs Lucene searches
Source operator that builds Pages out of the output of a TopFieldCollector (aka TopN)
Combines values at the given blocks with the same positions into a single position
for the blocks at the given channels.
Utilities to remove duplicates from multivalued fields.
Result of calling "hash" on a multivalue dedupe.
Removes duplicate values from multivalued positions.
Removes duplicate values from multivalued positions.
Removes duplicate values from multivalued positions.
Removes duplicate values from multivalued positions.
Removes duplicate values from multivalued positions.
"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 an
Operator to be returned by the tasks API.A
BytesRefBlock consists of a pair: an IntBlock for ordinals and a BytesRefVector for the dictionary.A
BytesRefVector consists of a pair: an IntVector for ordinals and a BytesRefVector for the dictionary.Unlike
HashAggregationOperator, this hash operator also extracts values or ordinals of the input documents.Sink operator that calls a given listener for each page received.
A page is a column-oriented data abstraction that allows data to be passed between operators in
batches.
Sink operator that's useful for passing off pages to a
Consumer.A subset of a
LeafReaderContext.Generates a list of Lucene queries based on the input block.
A rate grouping aggregation definition for double.
A rate grouping aggregation definition for float.
A rate grouping aggregation definition for int.
A rate grouping aggregation definition for long.
A helper class that can be used to collect and merge response headers from multiple child requests.
Performs a
LEFT JOIN where many "right hand" pages are joined
against a "left hand" Page.Consumes
Pages and looks up each row in a pre-built table, and returns the
offsets of each row in the table.Factory for
RowInTableLookupOperator.Evaluates scores for a ExpressionScorer.
Evaluates the score of an expression one
Page at a time.A Factory for creating ExpressionScorers.
Context of each shard we're operating against.
Finds all fields with a single-value.
A sink operator - accepts input, produces no output.
A factory for creating sink operators.
A
TopNEncoder that encodes values to byte arrays that may be sorted directly.A source operator - produces output, accepts no input.
A factory for creating source operators.
A standard deviation aggregation definition for double.
A standard deviation aggregation definition for float.
A standard deviation aggregation definition for int.
A standard deviation aggregation definition for long.
This class provides operator factories for time-series aggregations.
Creates a source operator that takes advantage of the natural sorting of segments in a tsdb index.
Result from calling
BooleanBlock.toMask().An internal aggregate function that always emits intermediate (or partial) output regardless of the aggregate mode.
Encodes values for
TopNOperator.An operator that sorts "rows" of values by encoding the values to sort on, as bytes (using BytesRef).
Operator that extracts doc_values from a Lucene index out of pages that have been produced by
LuceneSourceOperator
and outputs them to a new column.Creates a factory for
ValuesSourceReaderOperator.Configuration for a field to load.
A dense Vector of single values.
Builds
Vectors.Utilities to collect warnings for running an executor.
Algorithm for calculating standard deviation, one value at a time.