Module org.elasticsearch.compute
Class AbstractPageMappingToIteratorOperator
java.lang.Object
org.elasticsearch.compute.operator.AbstractPageMappingToIteratorOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
- Direct Known Subclasses:
ColumnLoadOperator,RowInTableLookupOperator
Maps a single
Page into zero or more resulting pages.-
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 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal voidadds an input page to the operator.static org.elasticsearch.core.ReleasableIterator<Page> appendBlocks(Page page, org.elasticsearch.core.ReleasableIterator<? extends Block> toAdd) voidclose()notifies the operator that it won't be used anymore (i.e.final voidfinish()notifies the operator that it won't receive any more input pagesfinal Pagereturns non-null if output page available.final booleanwhether the operator has finished processing all input pages and made the corresponding output pages availablefinal booleanwhether the given operator can accept more input pagesprotected abstract org.elasticsearch.core.ReleasableIterator<Page> Build and Iterator of results for a new page.status()The status of the operator.status(long processNanos, int pagesReceived, int pagesEmitted, long rowsReceived, long rowsEmitted) abstract StringtoString()
-
Constructor Details
-
AbstractPageMappingToIteratorOperator
public AbstractPageMappingToIteratorOperator()
-
-
Method Details
-
receive
Build and Iterator of results for a new page. -
appendBlocks
-
toString
-
needsInput
public final boolean needsInput()Description copied from interface:Operatorwhether the given operator can accept more input pages- Specified by:
needsInputin interfaceOperator
-
addInput
Description copied from interface:Operatoradds an input page to the operator. only called when needsInput() == true and isFinished() == false -
finish
public final void finish()Description copied from interface:Operatornotifies the operator that it won't receive any more input pages -
isFinished
public final boolean isFinished()Description copied from interface:Operatorwhether 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 -
status
Description copied from interface:OperatorThe status of the operator. -
status
protected AbstractPageMappingToIteratorOperator.Status status(long processNanos, int pagesReceived, int pagesEmitted, long rowsReceived, long rowsEmitted) -
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
-