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

Enclosing class:

LuceneOperator

public abstract static class LuceneOperator.Factory
extends Object
implements SourceOperator.SourceOperatorFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected final DataPartitioning	dataPartitioning
protected final int	limit
protected final boolean	needsScore
protected final LuceneSliceQueue	sliceQueue
protected final int	taskConcurrency

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Factory(List<? extends ShardContext> contexts, Function<ShardContext,List<LuceneSliceQueue.QueryAndTags>> queryFunction, DataPartitioning dataPartitioning, Function<org.apache.lucene.search.Query,LuceneSliceQueue.PartitioningStrategy> autoStrategy, int docThresholdForAutoStrategy, int taskConcurrency, int limit, boolean needsScore, Function<ShardContext,org.apache.lucene.search.ScoreMode> scoreModeFunction)	Build the factory.

Method Summary

Modifier and Type	Method	Description
final int	limit()
final int	taskConcurrency()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.elasticsearch.compute.Describable

describe

Methods inherited from interface org.elasticsearch.compute.operator.SourceOperator.SourceOperatorFactory

get

Field Details

dataPartitioning

protected final DataPartitioning dataPartitioning

taskConcurrency

protected final int taskConcurrency

limit

protected final int limit

needsScore

protected final boolean needsScore

sliceQueue

protected final LuceneSliceQueue 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 docThresholdForAutoStrategy,
 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()