Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator.exchange

Class ExchangeBuffer

java.lang.Object

org.elasticsearch.compute.operator.exchange.ExchangeBuffer

public final class ExchangeBuffer
extends Object

Constructor Summary

Constructors

Constructor	Description
ExchangeBuffer(int maxSize)

Method Summary

Modifier and Type	Method	Description
void	addPage(Page page)
void	finish(boolean drainingPages)
boolean	isFinished()
boolean	noMoreInputs()
Page	pollPage()
IsBlockedResult	waitForReading()
IsBlockedResult	waitForWriting()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ExchangeBuffer

public ExchangeBuffer(int maxSize)

Method Details

addPage

public void addPage(Page page)

pollPage

public Page pollPage()

waitForWriting

public IsBlockedResult waitForWriting()

waitForReading

public IsBlockedResult waitForReading()

finish

public void finish(boolean drainingPages)

isFinished

public boolean isFinished()

noMoreInputs

public boolean noMoreInputs()