org.elasticsearch.action.bulk
Class BulkShardRequest

java.lang.Object
  org.elasticsearch.action.support.replication.ShardReplicationOperationRequest
      org.elasticsearch.action.bulk.BulkShardRequest

All Implemented Interfaces:

ActionRequest, Streamable

public class BulkShardRequest
extends ShardReplicationOperationRequest

Field Summary

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

DEFAULT_TIMEOUT, index, timeout

Method Summary

void	beforeLocalFork() Before we fork on a local thread, make sure we copy over the bytes if they are unsafe
void	readFrom(StreamInput in)
void	writeTo(StreamOutput out)

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

consistencyLevel, consistencyLevel, index, index, listenerThreaded, listenerThreaded, operationThreaded, operationThreaded, replicationType, replicationType, timeout, validate

Methods inherited from class java.lang.Object

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

Method Detail

beforeLocalFork

public void beforeLocalFork()

Before we fork on a local thread, make sure we copy over the bytes if they are unsafe

Overrides:

beforeLocalFork in class ShardReplicationOperationRequest

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Streamable

Overrides:

writeTo in class ShardReplicationOperationRequest

Throws:

IOException

readFrom

public void readFrom(StreamInput in)
              throws IOException

Specified by:

readFrom in interface Streamable

Overrides:

readFrom in class ShardReplicationOperationRequest

Throws:

IOException