Class RecoveryFileChunkRequest

All Implemented Interfaces:
Writeable, org.elasticsearch.core.RefCounted, TaskAwareRequest

public final class RecoveryFileChunkRequest extends RecoveryTransportRequest implements org.elasticsearch.core.RefCounted
  • Constructor Details

  • Method Details

    • recoveryId

      public long recoveryId()
    • shardId

      public ShardId shardId()
    • name

      public String name()
    • position

      public long position()
    • length

      public long length()
    • content

      public ReleasableBytesReference content()
    • totalTranslogOps

      public int totalTranslogOps()
    • sourceThrottleTimeInNanos

      public long sourceThrottleTimeInNanos()
    • writeTo

      public void writeTo(StreamOutput out) throws IOException
      Description copied from interface: Writeable
      Write this into the StreamOutput.
      Specified by:
      writeTo in interface Writeable
      Overrides:
      writeTo in class RecoveryTransportRequest
      Throws:
      IOException
    • toString

      public String toString()
      Overrides:
      toString in class TransportRequest
    • metadata

      public StoreFileMetadata metadata()
    • lastChunk

      public boolean lastChunk()
      Returns true if this chunk is the last chunk in the stream.
    • 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