Class TimeSeriesSourceOperatorFactory

java.lang.Object
org.elasticsearch.compute.lucene.LuceneOperator.Factory
org.elasticsearch.compute.lucene.TimeSeriesSourceOperatorFactory
All Implemented Interfaces:
Describable, Operator.OperatorFactory, SourceOperator.SourceOperatorFactory

public class TimeSeriesSourceOperatorFactory extends LuceneOperator.Factory
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.