public class BulkShardRequest extends ReplicatedWriteRequest<BulkShardRequest>
TransportRequest.Empty
WriteRequest.RefreshPolicy
IndicesRequest.Replaceable
DEFAULT_TIMEOUT, index, shardId, timeout, waitForActiveShards
Constructor and Description |
---|
BulkShardRequest() |
BulkShardRequest(ShardId shardId,
WriteRequest.RefreshPolicy refreshPolicy,
BulkItemRequest[] items) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getDescription()
Returns optional description of the request to be displayed by the task manager
|
java.lang.String[] |
indices()
Returns the array of indices that the action relates to
|
BulkItemRequest[] |
items() |
void |
onRetry()
This method is called before this replication request is retried
the first time.
|
void |
readFrom(StreamInput in)
Set this object's fields from a StreamInput.
|
java.lang.String |
toString() |
void |
writeTo(StreamOutput out)
Write this object's fields to a StreamOutput.
|
getRefreshPolicy, setRefreshPolicy
createTask, index, index, indicesOptions, setShardId, shardId, timeout, timeout, timeout, validate, waitForActiveShards, waitForActiveShards, waitForActiveShards
getShouldStoreResult
getParentTask, setParentTask
remoteAddress, remoteAddress
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setRefreshPolicy, validate
setParentTask
public BulkShardRequest()
public BulkShardRequest(ShardId shardId, WriteRequest.RefreshPolicy refreshPolicy, BulkItemRequest[] items)
public BulkItemRequest[] items()
public java.lang.String[] indices()
IndicesRequest
indices
in interface IndicesRequest
indices
in class ReplicationRequest<BulkShardRequest>
public void writeTo(StreamOutput out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
writeTo
in class ReplicatedWriteRequest<BulkShardRequest>
java.io.IOException
public void readFrom(StreamInput in) throws java.io.IOException
Streamable
readFrom
in interface Streamable
readFrom
in class ReplicatedWriteRequest<BulkShardRequest>
java.io.IOException
public java.lang.String toString()
toString
in class ReplicationRequest<BulkShardRequest>
public java.lang.String getDescription()
TaskAwareRequest
getDescription
in interface TaskAwareRequest
getDescription
in class ReplicationRequest<BulkShardRequest>
public void onRetry()
ReplicationRequest
onRetry
in class ReplicationRequest<BulkShardRequest>