IndicesRequest
, WriteRequest<BulkShardRequest>
, Streamable
, Writeable
, TaskAwareRequest
public class BulkShardRequest extends ReplicatedWriteRequest<BulkShardRequest>
IndicesRequest.Replaceable
TransportRequest.Empty
Writeable.Reader<V>, Writeable.Writer<V>
WriteRequest.RefreshPolicy
DEFAULT_TIMEOUT, index, shardId, timeout, waitForActiveShards
Constructor | Description |
---|---|
BulkShardRequest() |
|
BulkShardRequest(ShardId shardId,
WriteRequest.RefreshPolicy refreshPolicy,
BulkItemRequest[] items) |
Modifier and Type | Method | 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.
|
getShouldStoreResult
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRefreshPolicy, setRefreshPolicy
createTask, index, index, indicesOptions, setShardId, shardId, timeout, timeout, timeout, validate, waitForActiveShards, waitForActiveShards, waitForActiveShards
setParentTask
remoteAddress, remoteAddress
getParentTask, setParentTask
setRefreshPolicy, validate
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 interface Writeable
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>