Module org.elasticsearch.compute
Class LocalSourceOperator
java.lang.Object
org.elasticsearch.compute.operator.SourceOperator
org.elasticsearch.compute.operator.LocalSourceOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
- Direct Known Subclasses:
ShowOperator
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interfacestatic interfacestatic final recordstatic interfacestatic interfaceNested classes/interfaces inherited from class org.elasticsearch.compute.operator.SourceOperator
SourceOperator.SourceOperatorFactoryNested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator
Operator.OperatorFactory, Operator.Status -
Field Summary
FieldsFields inherited from interface org.elasticsearch.compute.operator.Operator
MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE -
Constructor Summary
ConstructorsConstructorDescriptionLocalSourceOperator(BlockFactory blockFactory, LocalSourceOperator.ListSupplier listSupplier) LocalSourceOperator(BlockFactory blockFactory, LocalSourceOperator.ObjectSupplier objectSupplier) LocalSourceOperator(LocalSourceOperator.BlockSupplier blockSupplier) LocalSourceOperator(LocalSourceOperator.PageSupplier pageSupplier) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()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 availableMethods inherited from class org.elasticsearch.compute.operator.SourceOperator
addInput, needsInput
-
Field Details
-
supplier
-
-
Constructor Details
-
LocalSourceOperator
public LocalSourceOperator(BlockFactory blockFactory, LocalSourceOperator.ObjectSupplier objectSupplier) -
LocalSourceOperator
public LocalSourceOperator(BlockFactory blockFactory, LocalSourceOperator.ListSupplier listSupplier) -
LocalSourceOperator
-
LocalSourceOperator
-
-
Method Details
-
finish
public void finish()Description copied from interface:Operatornotifies the operator that it won't receive any more input pages -
isFinished
public boolean isFinished()Description copied from interface:Operatorwhether the operator has finished processing all input pages and made the corresponding output pages available -
getOutput
Description copied from interface:Operatorreturns non-null if output page available. Only called when isFinished() == false -
close
public void close()Description copied from interface:Operatornotifies the operator that it won't be used anymore (i.e. none of the other methods called), and its resources can be cleaned up
-