IndicesRequest
, WriteRequest<R>
, Streamable
, Writeable
, TaskAwareRequest
BulkShardRequest
, DeleteRequest
, IndexRequest
, ResyncReplicationRequest
public abstract class ReplicatedWriteRequest<R extends ReplicatedWriteRequest<R>> extends ReplicationRequest<R> implements WriteRequest<R>
BulkShardRequest
, IndexRequest
, and DeleteRequest
.IndicesRequest.Replaceable
TransportRequest.Empty
Writeable.Reader<V>, Writeable.Writer<V>
WriteRequest.RefreshPolicy
DEFAULT_TIMEOUT, index, shardId, timeout, waitForActiveShards
Constructor | Description |
---|---|
ReplicatedWriteRequest() |
Constructor for deserialization.
|
ReplicatedWriteRequest(ShardId shardId) |
Modifier and Type | Method | Description |
---|---|---|
WriteRequest.RefreshPolicy |
getRefreshPolicy() |
Should this request trigger a refresh (WriteRequest.RefreshPolicy.IMMEDIATE), wait for a refresh (
WriteRequest.RefreshPolicy.WAIT_UNTIL), or proceed ignore refreshes entirely (WriteRequest.RefreshPolicy.NONE, the default).
|
void |
readFrom(StreamInput in) |
Set this object's fields from a StreamInput.
|
R |
setRefreshPolicy(WriteRequest.RefreshPolicy refreshPolicy) |
Should this request trigger a refresh (WriteRequest.RefreshPolicy.IMMEDIATE), wait for a refresh (
WriteRequest.RefreshPolicy.WAIT_UNTIL), or proceed ignore refreshes entirely (WriteRequest.RefreshPolicy.NONE, the default).
|
void |
writeTo(StreamOutput out) |
Write this object's fields to a StreamOutput.
|
getShouldStoreResult
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createTask, getDescription, index, index, indices, indicesOptions, onRetry, setShardId, shardId, timeout, timeout, timeout, toString, validate, waitForActiveShards, waitForActiveShards, waitForActiveShards
setParentTask
remoteAddress, remoteAddress
getParentTask, setParentTask
setRefreshPolicy, validate
public ReplicatedWriteRequest()
public ReplicatedWriteRequest(ShardId shardId)
public R setRefreshPolicy(WriteRequest.RefreshPolicy refreshPolicy)
WriteRequest
setRefreshPolicy
in interface WriteRequest<R extends ReplicatedWriteRequest<R>>
public WriteRequest.RefreshPolicy getRefreshPolicy()
WriteRequest
getRefreshPolicy
in interface WriteRequest<R extends ReplicatedWriteRequest<R>>
public void readFrom(StreamInput in) throws java.io.IOException
Streamable
readFrom
in interface Streamable
readFrom
in class ReplicationRequest<R extends ReplicatedWriteRequest<R>>
java.io.IOException
public void writeTo(StreamOutput out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
writeTo
in interface Writeable
writeTo
in class ReplicationRequest<R extends ReplicatedWriteRequest<R>>
java.io.IOException