Module org.elasticsearch.compute
Package org.elasticsearch.compute.lucene
Class LuceneOperator.Factory
java.lang.Object
org.elasticsearch.compute.lucene.LuceneOperator.Factory
- All Implemented Interfaces:
Describable,Operator.OperatorFactory,SourceOperator.SourceOperatorFactory
- Direct Known Subclasses:
LuceneCountOperator.Factory,LuceneMaxFactory,LuceneMinFactory,LuceneSourceOperator.Factory,LuceneTopNSourceOperator.Factory,TimeSeriesSourceOperatorFactory
- Enclosing class:
LuceneOperator
public abstract static class LuceneOperator.Factory
extends Object
implements SourceOperator.SourceOperatorFactory
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final DataPartitioningprotected final intprotected final booleanprotected final LuceneSliceQueueprotected final int -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedFactory(List<? extends ShardContext> contexts, Function<ShardContext, List<LuceneSliceQueue.QueryAndTags>> queryFunction, DataPartitioning dataPartitioning, Function<org.apache.lucene.search.Query, LuceneSliceQueue.PartitioningStrategy> autoStrategy, int taskConcurrency, int limit, boolean needsScore, Function<ShardContext, org.apache.lucene.search.ScoreMode> scoreModeFunction) Build the factory. -
Method Summary
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.compute.Describable
describeMethods inherited from interface org.elasticsearch.compute.operator.SourceOperator.SourceOperatorFactory
get
-
Field Details
-
dataPartitioning
-
taskConcurrency
protected final int taskConcurrency -
limit
protected final int limit -
needsScore
protected final boolean needsScore -
sliceQueue
-
-
Constructor Details
-
Factory
protected Factory(List<? extends ShardContext> contexts, Function<ShardContext, List<LuceneSliceQueue.QueryAndTags>> queryFunction, DataPartitioning dataPartitioning, Function<org.apache.lucene.search.Query, LuceneSliceQueue.PartitioningStrategy> autoStrategy, int taskConcurrency, int limit, boolean needsScore, Function<ShardContext, org.apache.lucene.search.ScoreMode> scoreModeFunction) Build the factory.- Parameters:
needsScore- Whether the score is needed.
-
-
Method Details
-
taskConcurrency
public final int taskConcurrency() -
limit
public final int limit()
-