Module org.elasticsearch.compute
Interface ExchangeSource
public interface ExchangeSource
Source for exchanging data
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionintReturns the number of pages that are buffered in this exchange sourcevoidfinish()Called when the source has enough input pagesbooleanWhether the associated sinks are finished and pages are processed.pollPage()Remove the page from this source if any; otherwise, returns nullAllows callers to stop reading from the source when it's blocked
-
Method Details
-
pollPage
Page pollPage()Remove the page from this source if any; otherwise, returns null -
finish
void finish()Called when the source has enough input pages -
isFinished
boolean isFinished()Whether the associated sinks are finished and pages are processed. -
bufferSize
int bufferSize()Returns the number of pages that are buffered in this exchange source -
waitForReading
IsBlockedResult waitForReading()Allows callers to stop reading from the source when it's blocked
-