Module org.elasticsearch.compute
Interface ExchangeSink
public interface ExchangeSink
Sink for exchanging data
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionvoidaddCompletionListener(ActionListener<Void> listener) Adds a listener that will be notified when this exchange sink is finished.voidadds a new page to this sinkvoidfinish()called once all pages have been added (seeaddPage(Page)).booleanWhether the sink has received all pagesWhether the sink is blocked on adding more pages
-
Method Details
-
addPage
adds a new page to this sink -
finish
void finish()called once all pages have been added (seeaddPage(Page)). -
isFinished
boolean isFinished()Whether the sink has received all pages -
addCompletionListener
Adds a listener that will be notified when this exchange sink is finished. -
waitForWriting
IsBlockedResult waitForWriting()Whether the sink is blocked on adding more pages
-