public class BulkShardResponse extends ReplicationResponse implements WriteResponse
ReplicationResponse.ShardInfoTransportResponse.EmptyEMPTY| Modifier and Type | Method and Description |
|---|---|
BulkItemResponse[] |
getResponses() |
ShardId |
getShardId() |
void |
readFrom(StreamInput in)
Set this object's fields from a StreamInput.
|
void |
setForcedRefresh(boolean forcedRefresh)
Mark the response as having forced a refresh? Requests that set
WriteRequest.setRefreshPolicy(RefreshPolicy) to
WriteRequest.RefreshPolicy.IMMEDIATE should always mark this as true. |
void |
writeTo(StreamOutput out)
Write this object's fields to a StreamOutput.
|
getShardInfo, setShardInforemoteAddress, remoteAddresspublic ShardId getShardId()
public BulkItemResponse[] getResponses()
public void setForcedRefresh(boolean forcedRefresh)
WriteResponseWriteRequest.setRefreshPolicy(RefreshPolicy) to
WriteRequest.RefreshPolicy.IMMEDIATE should always mark this as true. Requests that set it to WriteRequest.RefreshPolicy.WAIT_UNTIL will only
set this to true if they run out of refresh listener slots (see IndexSettings.MAX_REFRESH_LISTENERS_PER_SHARD).setForcedRefresh in interface WriteResponsepublic void readFrom(StreamInput in) throws java.io.IOException
StreamablereadFrom in interface StreamablereadFrom in class ReplicationResponsejava.io.IOExceptionpublic void writeTo(StreamOutput out) throws java.io.IOException
StreamablewriteTo in interface StreamablewriteTo in class ReplicationResponsejava.io.IOException