Uses of Interface
org.apache.druid.query.operator.Operator.Receiver

Packages that use Operator.Receiver

Package	Description
org.apache.druid.query.operator
org.apache.druid.query.operator.join

Uses of Operator.Receiver in org.apache.druid.query.operator

Classes in org.apache.druid.query.operator that implement Operator.Receiver

Modifier and Type	Class	Description
protected static class	AbstractPartitioningOperator.AbstractReceiver

Fields in org.apache.druid.query.operator declared as Operator.Receiver

Modifier and Type	Field	Description
protected final Operator.Receiver	AbstractPartitioningOperator.AbstractReceiver.delegate

Methods in org.apache.druid.query.operator that return Operator.Receiver

Modifier and Type	Method	Description
protected abstract Operator.Receiver	AbstractPartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
protected Operator.Receiver	GlueingPartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
protected Operator.Receiver	NaivePartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)

Methods in org.apache.druid.query.operator with parameters of type Operator.Receiver

Modifier and Type	Method	Description
protected abstract Operator.Receiver	AbstractPartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
protected Operator.Receiver	GlueingPartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
protected Operator.Receiver	NaivePartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
static void	Operator.go(Operator op, Operator.Receiver receiver)	Convenience method to run an Operator until completion.
Closeable	AbstractPartitioningOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)
abstract Closeable	AbstractSortOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)
Closeable	LimitTimeIntervalOperator.goOrContinue(Closeable continuationObject, Operator.Receiver receiver)
Closeable	NaiveSortOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)
Closeable	Operator.goOrContinue(Closeable continuationObject, Operator.Receiver receiver)	This is the primary workhorse method of an Operator.
Closeable	PartitionSortOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)
Closeable	ScanOperator.goOrContinue(Closeable continuationObject, Operator.Receiver receiver)
Closeable	SegmentToRowsAndColumnsOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)
Closeable	SequenceOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)
Closeable	WindowProcessorOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)
protected abstract AbstractPartitioningOperator.HandleContinuationResult	AbstractPartitioningOperator.handleContinuation(Operator.Receiver receiver, AbstractPartitioningOperator.Continuation cont)
protected AbstractPartitioningOperator.HandleContinuationResult	GlueingPartitioningOperator.handleContinuation(Operator.Receiver receiver, AbstractPartitioningOperator.Continuation cont)
protected AbstractPartitioningOperator.HandleContinuationResult	NaivePartitioningOperator.handleContinuation(Operator.Receiver receiver, AbstractPartitioningOperator.Continuation cont)
protected AbstractPartitioningOperator.HandleContinuationResult	AbstractPartitioningOperator.handleNonGoCases(Operator.Signal signal, Iterator<RowsAndColumns> iter, Operator.Receiver receiver, AbstractPartitioningOperator.Continuation cont)

Constructors in org.apache.druid.query.operator with parameters of type Operator.Receiver

Modifier	Constructor	Description
	AbstractReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder, List<String> partitionColumns)

Uses of Operator.Receiver in org.apache.druid.query.operator.join

Methods in org.apache.druid.query.operator.join with parameters of type Operator.Receiver

Modifier and Type	Method	Description
Closeable	SortedInnerJoinOperator.goOrContinue(Closeable continuation, Operator.Receiver receiver)