org.elasticsearch.action.support.replication
Class IndexReplicationOperationRequest
java.lang.Object
org.elasticsearch.action.support.replication.IndexReplicationOperationRequest
- All Implemented Interfaces:
- ActionRequest, Streamable
- Direct Known Subclasses:
- IndexDeleteByQueryRequest, IndexDeleteRequest
public class IndexReplicationOperationRequest
- extends Object
- implements ActionRequest
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
timeout
protected TimeValue timeout
index
protected String index
replicationType
protected ReplicationType replicationType
consistencyLevel
protected WriteConsistencyLevel consistencyLevel
IndexReplicationOperationRequest
public IndexReplicationOperationRequest()
timeout
public TimeValue timeout()
index
public String index()
index
public IndexReplicationOperationRequest index(String index)
listenerThreaded
public boolean listenerThreaded()
- Description copied from interface:
ActionRequest
- Should the response listener be executed on a thread or not.
When not executing on a thread, it will either be executed on the calling thread, or
on an expensive, IO based, thread.
- Specified by:
listenerThreaded
in interface ActionRequest
replicationType
public ReplicationType replicationType()
consistencyLevel
public WriteConsistencyLevel consistencyLevel()
listenerThreaded
public IndexReplicationOperationRequest listenerThreaded(boolean threadedListener)
- Description copied from interface:
ActionRequest
- Sets if the response listener be executed on a thread or not.
- Specified by:
listenerThreaded
in interface ActionRequest
validate
public ActionRequestValidationException validate()
- Specified by:
validate
in interface ActionRequest
readFrom
public void readFrom(StreamInput in)
throws IOException
- Specified by:
readFrom
in interface Streamable
- Throws:
IOException
writeTo
public void writeTo(StreamOutput out)
throws IOException
- Specified by:
writeTo
in interface Streamable
- Throws:
IOException
Copyright © 2009-2012. All Rights Reserved.