java.lang.Object
org.elasticsearch.compute.operator.SinkOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
- Direct Known Subclasses:
ExchangeSinkOperator,OutputOperator,PageConsumerOperator
A sink operator - accepts input, produces no output.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interfaceA factory for creating sink operators.Nested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator
Operator.OperatorFactory, Operator.Status -
Field Summary
Fields inherited from interface org.elasticsearch.compute.operator.Operator
MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE -
Constructor Summary
Constructors -
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.operator.Operator
close, finish, isBlocked, isFinished, needsInput, status
-
Constructor Details
-
SinkOperator
public SinkOperator()
-
-
Method Details
-
getOutput
A sink operator produces no output - unconditionally throws UnsupportedOperationException -
doAddInput
-
addInput
Description copied from interface:Operatoradds an input page to the operator. only called when needsInput() == true and isFinished() == false
-