Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator.exchange

Class ExchangeResponse

java.lang.Object

org.elasticsearch.transport.TransportMessage

org.elasticsearch.transport.TransportResponse

org.elasticsearch.compute.operator.exchange.ExchangeResponse

All Implemented Interfaces:

Closeable, AutoCloseable, Writeable, RefCounted, Releasable

public final class ExchangeResponse
extends TransportResponse
implements Releasable

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields inherited from interface org.elasticsearch.core.RefCounted

ALWAYS_REFERENCED

Constructor Summary

Constructors

Constructor	Description
ExchangeResponse(BlockFactory blockFactory, Page page, boolean finished)
ExchangeResponse(BlockStreamInput in)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	decRef()
boolean	equals(Object o)
boolean	finished()	Returns true if the RemoteSink is already completed.
int	hashCode()
boolean	hasReferences()
void	incRef()
long	ramBytesUsedByPage()
Page	takePage()	Take the ownership of the page responded by RemoteSink.
boolean	tryIncRef()
void	writeTo(StreamOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.core.RefCounted

mustIncRef

Constructor Details

ExchangeResponse

public ExchangeResponse(BlockFactory blockFactory,
 Page page,
 boolean finished)

ExchangeResponse

public ExchangeResponse(BlockStreamInput in)
                 throws IOException

Throws:

IOException

Method Details

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Writeable

Throws:

IOException

takePage

@Nullable
public Page takePage()

Take the ownership of the page responded by RemoteSink. This can be null and out of order.

ramBytesUsedByPage

public long ramBytesUsedByPage()

finished

public boolean finished()

Returns true if the RemoteSink is already completed. In this case, the ExchangeSourceHandler can stop polling pages and finish itself.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

incRef

public void incRef()

Specified by:

incRef in interface RefCounted

Overrides:

incRef in class TransportMessage

tryIncRef

public boolean tryIncRef()

Specified by:

tryIncRef in interface RefCounted

Overrides:

tryIncRef in class TransportMessage

decRef

public boolean decRef()

Specified by:

decRef in interface RefCounted

Overrides:

decRef in class TransportMessage

hasReferences

public boolean hasReferences()

Specified by:

hasReferences in interface RefCounted

Overrides:

hasReferences in class TransportMessage

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Releasable