Module org.elasticsearch.compute
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,org.elasticsearch.core.RefCounted,org.elasticsearch.core.Releasable
public final class ExchangeResponse
extends TransportResponse
implements org.elasticsearch.core.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 -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()booleandecRef()booleanbooleanfinished()Returns true if theRemoteSinkis already completed.inthashCode()booleanvoidincRef()longtakePage()Take the ownership of the page responded byRemoteSink.booleanvoidwriteTo(StreamOutput out) Methods inherited from class org.elasticsearch.transport.TransportMessage
remoteAddress, remoteAddressMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.core.RefCounted
mustIncRef
-
Constructor Details
-
ExchangeResponse
-
ExchangeResponse
- Throws:
IOException
-
-
Method Details
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
takePage
Take the ownership of the page responded byRemoteSink. This can be null and out of order. -
ramBytesUsedByPage
public long ramBytesUsedByPage() -
finished
public boolean finished()Returns true if theRemoteSinkis already completed. In this case, theExchangeSourceHandlercan stop polling pages and finish itself. -
equals
-
hashCode
public int hashCode() -
incRef
public void incRef()- Specified by:
incRefin interfaceorg.elasticsearch.core.RefCounted- Overrides:
incRefin classTransportMessage
-
tryIncRef
public boolean tryIncRef()- Specified by:
tryIncRefin interfaceorg.elasticsearch.core.RefCounted- Overrides:
tryIncRefin classTransportMessage
-
decRef
public boolean decRef()- Specified by:
decRefin interfaceorg.elasticsearch.core.RefCounted- Overrides:
decRefin classTransportMessage
-
hasReferences
public boolean hasReferences()- Specified by:
hasReferencesin interfaceorg.elasticsearch.core.RefCounted- Overrides:
hasReferencesin classTransportMessage
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceorg.elasticsearch.core.Releasable
-