Module org.elasticsearch.compute
Package org.elasticsearch.compute.lucene
Class TimeSeriesSortedSourceOperatorFactory
java.lang.Object
org.elasticsearch.compute.lucene.LuceneOperator.Factory
org.elasticsearch.compute.lucene.TimeSeriesSortedSourceOperatorFactory
- All Implemented Interfaces:
Describable,Operator.OperatorFactory,SourceOperator.SourceOperatorFactory
Creates a source operator that takes advantage of the natural sorting of segments in a tsdb index.
This source operator loads the _tsid and @timestamp fields, which is used for emitting documents in the correct order. These field values are included in the page as seperate blocks and downstream operators can make use of these loaded time series ids and timestamps.
The source operator includes all documents of a time serie with the same page. So the same time series never exists in multiple pages. Downstream operators can make use of this implementation detail.
This operator currently only supports shard level concurrency. A new concurrency mechanism should be introduced at the time serie level in order to read tsdb indices in parallel.
-
Field Summary
Fields inherited from class org.elasticsearch.compute.lucene.LuceneOperator.Factory
dataPartitioning, limit, scoreMode, sliceQueue, taskConcurrency -
Method Summary
Modifier and TypeMethodDescriptioncreate(int limit, int maxPageSize, int taskConcurrency, List<? extends ShardContext> searchContexts, Function<ShardContext, org.apache.lucene.search.Query> queryFunction) describe()Returns a description of the component.get(DriverContext driverContext) Creates a new source operator.Methods inherited from class org.elasticsearch.compute.lucene.LuceneOperator.Factory
limit, taskConcurrency
-
Method Details
-
get
Description copied from interface:SourceOperator.SourceOperatorFactoryCreates a new source operator. -
describe
Description copied from interface:DescribableReturns a description of the component. This description can be more specific than Object::toString.- Returns:
- the description
-
create
public static TimeSeriesSortedSourceOperatorFactory create(int limit, int maxPageSize, int taskConcurrency, List<? extends ShardContext> searchContexts, Function<ShardContext, org.apache.lucene.search.Query> queryFunction)
-