java.lang.Object
org.elasticsearch.compute.operator.SampleOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator
Operator.OperatorFactory -
Field Summary
Fields inherited from interface org.elasticsearch.compute.operator.Operator
MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE -
Method Summary
Modifier and TypeMethodDescriptionvoidadds an input page to the operator.voidclose()notifies the operator that it won't be used anymore (i.e.voidfinish()notifies the operator that it won't receive any more input pagesreturns non-null if output page available.booleanwhether the operator has finished processing all input pages and made the corresponding output pages availablebooleanwhether the given operator can accept more input pagesstatus()The status of the operator.toString()
-
Method Details
-
needsInput
public boolean needsInput()whether the given operator can accept more input pages- Specified by:
needsInputin interfaceOperator
-
addInput
adds an input page to the operator. only called when needsInput() == true and isFinished() == false- Specified by:
addInputin interfaceOperator- Parameters:
page-- Throws:
UnsupportedOperationException- if the operator is aSourceOperator
-
finish
public void finish()notifies the operator that it won't receive any more input pages -
isFinished
public boolean isFinished()whether the operator has finished processing all input pages and made the corresponding output pages available- Specified by:
isFinishedin interfaceOperator
-
getOutput
Description copied from interface:Operatorreturns non-null if output page available. Only called when isFinished() == false -
close
public void close()notifies the operator that it won't be used anymore (i.e. none of the other methods called), and its resources can be cleaned up -
toString
-
status
Description copied from interface:OperatorThe status of the operator.
-