Streamable
, Writeable
, TaskAwareRequest
ReindexRequest
, UpdateByQueryRequest
public abstract class AbstractBulkIndexByScrollRequest<Self extends AbstractBulkIndexByScrollRequest<Self>> extends AbstractBulkByScrollRequest<Self>
TransportRequest.Empty
Writeable.Reader<V>, Writeable.Writer<V>
AUTO_SLICES, AUTO_SLICES_VALUE, SIZE_ALL_MATCHES
Modifier | Constructor | Description |
---|---|---|
|
AbstractBulkIndexByScrollRequest() |
Constructor for deserialization.
|
protected |
AbstractBulkIndexByScrollRequest(SearchRequest searchRequest,
boolean setDefaults) |
Constructor for actual use.
|
Modifier and Type | Method | Description |
---|---|---|
protected Self |
doForSlice(Self request,
TaskId slicingTask,
int totalSlices) |
Setup a clone of this request with the information needed to process a slice of it.
|
Script |
getScript() |
Script to modify the documents before they are processed.
|
void |
readFrom(StreamInput in) |
Set this object's fields from a StreamInput.
|
protected void |
searchToString(java.lang.StringBuilder b) |
Append a short description of the search request to a StringBuilder.
|
Self |
setScript(Script script) |
Script to modify the documents before they are processed.
|
void |
writeTo(StreamOutput out) |
Write this object's fields to a StreamOutput.
|
createTask, forSlice, getDescription, getMaxRetries, getRequestsPerSecond, getRetryBackoffInitialTime, getScrollTime, getSearchRequest, getShouldStoreResult, getSize, getSlices, getTimeout, getWaitForActiveShards, isAbortOnVersionConflict, isRefresh, self, setAbortOnVersionConflict, setConflicts, setMaxRetries, setRefresh, setRequestsPerSecond, setRetryBackoffInitialTime, setScroll, setShouldStoreResult, setSize, setSlices, setTimeout, setWaitForActiveShards, setWaitForActiveShards, validate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
newWriteableReader
setParentTask
remoteAddress, remoteAddress
getParentTask, setParentTask
public AbstractBulkIndexByScrollRequest()
protected AbstractBulkIndexByScrollRequest(SearchRequest searchRequest, boolean setDefaults)
searchRequest
- the search request to execute to get the documents to processsetDefaults
- should this request set the defaults on the search request? Usually set to true but leave it false to support
request slicingpublic Script getScript()
public Self setScript(@Nullable Script script)
protected Self doForSlice(Self request, TaskId slicingTask, int totalSlices)
AbstractBulkByScrollRequest
doForSlice
in class AbstractBulkByScrollRequest<Self extends AbstractBulkIndexByScrollRequest<Self>>
public void readFrom(StreamInput in) throws java.io.IOException
Streamable
readFrom
in interface Streamable
readFrom
in class AbstractBulkByScrollRequest<Self extends AbstractBulkIndexByScrollRequest<Self>>
java.io.IOException
public void writeTo(StreamOutput out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
writeTo
in interface Writeable
writeTo
in class AbstractBulkByScrollRequest<Self extends AbstractBulkIndexByScrollRequest<Self>>
java.io.IOException
protected void searchToString(java.lang.StringBuilder b)
AbstractBulkByScrollRequest
searchToString
in class AbstractBulkByScrollRequest<Self extends AbstractBulkIndexByScrollRequest<Self>>