org.elasticsearch.action.support.broadcast
Class BroadcastOperationRequest

java.lang.Object
  org.elasticsearch.action.support.broadcast.BroadcastOperationRequest

All Implemented Interfaces:

ActionRequest, Streamable

Direct Known Subclasses:

ClearIndicesCacheRequest, CountRequest, FlushRequest, GatewaySnapshotRequest, IndicesSegmentsRequest, IndicesStatsRequest, IndicesStatusRequest, OptimizeRequest, RefreshRequest, ValidateQueryRequest

public abstract class BroadcastOperationRequest
extends Object
implements ActionRequest

Field Summary

protected String[]

indices

Constructor Summary

protected	BroadcastOperationRequest()
protected	BroadcastOperationRequest(String[] indices)

Method Summary

protected void	beforeLocalFork()
protected void	beforeStart()
IgnoreIndices	ignoreIndices()
BroadcastOperationRequest	ignoreIndices(IgnoreIndices ignoreIndices)
String[]	indices()
BroadcastOperationRequest	indices(String... indices)
boolean	listenerThreaded() Should the listener be called on a separate thread if needed.
BroadcastOperationRequest	listenerThreaded(boolean listenerThreaded) Should the listener be called on a separate thread if needed.
BroadcastOperationThreading	operationThreading() Controls the operation threading model.
BroadcastOperationRequest	operationThreading(BroadcastOperationThreading operationThreading) Controls the operation threading model.
BroadcastOperationRequest	operationThreading(String operationThreading) Controls the operation threading model.
void	readFrom(StreamInput in)
ActionRequestValidationException	validate()
void	writeTo(StreamOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

indices

protected String[] indices

Constructor Detail

BroadcastOperationRequest

protected BroadcastOperationRequest()

BroadcastOperationRequest

protected BroadcastOperationRequest(String[] indices)

Method Detail

indices

public String[] indices()

indices

public BroadcastOperationRequest indices(String... indices)

validate

public ActionRequestValidationException validate()

Specified by:

validate in interface ActionRequest

listenerThreaded

public boolean listenerThreaded()

Should the listener be called on a separate thread if needed.

Specified by:

listenerThreaded in interface ActionRequest

listenerThreaded

public BroadcastOperationRequest listenerThreaded(boolean listenerThreaded)

Should the listener be called on a separate thread if needed.

Specified by:

listenerThreaded in interface ActionRequest

operationThreading

public BroadcastOperationThreading operationThreading()

Controls the operation threading model.

operationThreading

public BroadcastOperationRequest operationThreading(BroadcastOperationThreading operationThreading)

Controls the operation threading model.

operationThreading

public BroadcastOperationRequest operationThreading(String operationThreading)

Controls the operation threading model.

ignoreIndices

public IgnoreIndices ignoreIndices()

ignoreIndices

public BroadcastOperationRequest ignoreIndices(IgnoreIndices ignoreIndices)

beforeStart

protected void beforeStart()

beforeLocalFork

protected void beforeLocalFork()

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Streamable

Throws:

IOException

readFrom

public void readFrom(StreamInput in)
              throws IOException

Specified by:

readFrom in interface Streamable

Throws:

IOException