Class TransportBroadcastByNodeAction.NodeRequest

org.elasticsearch.transport.TransportMessage
org.elasticsearch.transport.TransportRequest
org.elasticsearch.action.support.broadcast.node.TransportBroadcastByNodeAction.NodeRequest
All Implemented Interfaces:
IndicesRequest, Writeable, org.elasticsearch.core.RefCounted, TaskAwareRequest
Enclosing class:
TransportBroadcastByNodeAction<Request extends BroadcastRequest<Request>,​Response extends BroadcastResponse,​ShardOperationResult extends Writeable>

public class TransportBroadcastByNodeAction.NodeRequest extends TransportRequest implements IndicesRequest
  • Field Details

  • Constructor Details

    • NodeRequest

      public NodeRequest(StreamInput in) throws
      Throws:
    • NodeRequest

      public NodeRequest( nodeId, Request request, <ShardRouting> shards)
  • Method Details

    • getShards

      public <ShardRouting> getShards()
    • getNodeId

      public  getNodeId()
    • indices

      public [] indices()
      Description copied from interface: IndicesRequest
      Returns the array of indices that the action relates to
      Specified by:
      indices in interface IndicesRequest
    • indicesOptions

      public IndicesOptions indicesOptions()
      Description copied from interface: IndicesRequest
      Returns the indices options used to resolve indices. They tell for instance whether a single index is accepted, whether an empty array will be converted to _all, and how wildcards will be expanded if needed.
      Specified by:
      indicesOptions in interface IndicesRequest
    • writeTo

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

      public Task createTask(long id,  type,  action, TaskId parentTaskId, <,​> headers)
      Description copied from interface: TaskAwareRequest
      Returns the task object that should be used to keep track of the processing of the request.
      Specified by:
      createTask in interface TaskAwareRequest