Package org.elasticsearch.action.bulk

Class BulkShardResponse

java.lang.Object

org.elasticsearch.transport.TransportMessage

org.elasticsearch.transport.TransportResponse

org.elasticsearch.action.ActionResponse

org.elasticsearch.action.support.replication.ReplicationResponse

org.elasticsearch.action.bulk.BulkShardResponse

All Implemented Interfaces:

WriteResponse, Streamable, Writeable

public class BulkShardResponse
extends ReplicationResponse
implements WriteResponse

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.support.replication.ReplicationResponse

ReplicationResponse.ShardInfo

Nested classes/interfaces inherited from class org.elasticsearch.transport.TransportResponse

TransportResponse.Empty

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields inherited from class org.elasticsearch.action.support.replication.ReplicationResponse

EMPTY

Constructor Summary

Constructors

Constructor	Description
BulkShardResponse(ShardId shardId, BulkItemResponse[] responses)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from class org.elasticsearch.action.support.replication.ReplicationResponse

getShardInfo, setShardInfo

Methods inherited from interface org.elasticsearch.common.io.stream.Streamable

newWriteableReader

Methods inherited from class org.elasticsearch.transport.TransportMessage

remoteAddress, remoteAddress

Constructor Detail

BulkShardResponse

public BulkShardResponse(ShardId shardId,
                         BulkItemResponse[] responses)

Method Detail

getShardId

public ShardId getShardId()

getResponses

public BulkItemResponse[] getResponses()

setForcedRefresh

public void setForcedRefresh(boolean forcedRefresh)

Description copied from interface: WriteResponse

Mark the response as having forced a refresh? Requests that set WriteRequest.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).

Specified by:

setForcedRefresh in interface WriteResponse

readFrom

public void readFrom(StreamInput in)
              throws java.io.IOException

Description copied from interface: Streamable

Set this object's fields from a StreamInput.

Specified by:

readFrom in interface Streamable

Overrides:

readFrom in class ReplicationResponse

Throws:

java.io.IOException

writeTo

public void writeTo(StreamOutput out)
             throws java.io.IOException

Description copied from interface: Streamable

Write this object's fields to a StreamOutput.

Specified by:

writeTo in interface Streamable

Specified by:

writeTo in interface Writeable

Overrides:

writeTo in class ReplicationResponse

Throws:

java.io.IOException