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
  • Constructor Details

  • 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 org.elasticsearch.core.RefCounted
      Overrides:
      incRef in class TransportMessage
    • tryIncRef

      public boolean tryIncRef()
      Specified by:
      tryIncRef in interface org.elasticsearch.core.RefCounted
      Overrides:
      tryIncRef in class TransportMessage
    • decRef

      public boolean decRef()
      Specified by:
      decRef in interface org.elasticsearch.core.RefCounted
      Overrides:
      decRef in class TransportMessage
    • hasReferences

      public boolean hasReferences()
      Specified by:
      hasReferences in interface org.elasticsearch.core.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 org.elasticsearch.core.Releasable