Class ShardFetchRequest

All Implemented Interfaces:
Writeable, TaskAwareRequest
Direct Known Subclasses:

public class ShardFetchRequest
extends TransportRequest
Shard level fetch base request. Holds all the info needed to execute a fetch. Used with search scroll as the original request doesn't hold indices.
  • Constructor Details

    • ShardFetchRequest

      public ShardFetchRequest()
    • ShardFetchRequest

      public ShardFetchRequest​(long id, com.carrotsearch.hppc.IntArrayList list, lastEmittedDoc)
    • ShardFetchRequest

      public ShardFetchRequest​(StreamInput in) throws
  • Method Details

    • writeTo

      public void writeTo​(StreamOutput out) throws
      Description copied from interface: Writeable
      Write this into the StreamOutput.
      Specified by:
      writeTo in interface Writeable
      writeTo in class TransportRequest
    • id

      public long id()
    • docIds

      public int[] docIds()
    • docIdsSize

      public int docIdsSize()
    • lastEmittedDoc

      public lastEmittedDoc()
    • createTask

      public Task createTask​(long id, java.lang.String type, java.lang.String action, TaskId parentTaskId, java.util.Map<java.lang.String,​java.lang.String> headers)
      Description copied from interface: TaskAwareRequest
      Returns the task object that should be used to keep track of the processing of the request.
    • getDescription

      public java.lang.String getDescription()
      Description copied from interface: TaskAwareRequest
      Returns optional description of the request to be displayed by the task manager