Package | Description |
---|---|
org.elasticsearch.action.bulk | |
org.elasticsearch.client |
The client module allowing to easily perform actions/operations.
|
org.elasticsearch.client.support | |
org.elasticsearch.client.transport |
Modifier and Type | Method and Description |
---|---|
BulkRequest |
BulkRequest.add(ActionRequest... requests)
Adds a list of requests to be executed.
|
BulkRequest |
BulkRequest.add(ActionRequest request) |
BulkRequest |
BulkRequest.add(ActionRequest request,
Object payload) |
BulkRequest |
BulkRequest.add(byte[] data,
int from,
int length,
boolean contentUnsafe)
Adds a framed data in binary format
|
BulkRequest |
BulkRequest.add(byte[] data,
int from,
int length,
boolean contentUnsafe,
String defaultIndex,
String defaultType)
Adds a framed data in binary format
|
BulkRequest |
BulkRequest.add(BytesReference data,
boolean contentUnsafe,
String defaultIndex,
String defaultType)
Adds a framed data in binary format
|
BulkRequest |
BulkRequest.add(BytesReference data,
boolean contentUnsafe,
String defaultIndex,
String defaultType,
boolean allowExplicitIndex)
Adds a framed data in binary format
|
BulkRequest |
BulkRequest.add(BytesReference data,
boolean contentUnsafe,
String defaultIndex,
String defaultType,
String defaultRouting,
Object payload,
boolean allowExplicitIndex) |
BulkRequest |
BulkRequest.add(DeleteRequest request)
Adds an
DeleteRequest to the list of actions to execute. |
BulkRequest |
BulkRequest.add(DeleteRequest request,
Object payload) |
BulkRequest |
BulkRequest.add(IndexRequest request)
Adds an
IndexRequest to the list of actions to execute. |
BulkRequest |
BulkRequest.add(IndexRequest request,
Object payload) |
BulkRequest |
BulkRequest.add(Iterable<ActionRequest> requests)
Adds a list of requests to be executed.
|
BulkRequest |
BulkRequest.add(UpdateRequest request)
Adds an
UpdateRequest to the list of actions to execute. |
BulkRequest |
BulkRequest.add(UpdateRequest request,
Object payload) |
BulkRequest |
BulkRequest.consistencyLevel(WriteConsistencyLevel consistencyLevel)
Sets the consistency level of write.
|
BulkRequest |
TransportBulkAction.newRequestInstance() |
BulkRequest |
BulkRequest.refresh(boolean refresh)
Should a refresh be executed post this bulk operation causing the operations to
be searchable.
|
BulkRequest |
BulkRequest.replicationType(ReplicationType replicationType)
Set the replication type for this operation.
|
BulkRequest |
BulkRequest.timeout(String timeout)
A timeout to wait if the index operation can't be performed immediately.
|
BulkRequest |
BulkRequest.timeout(TimeValue timeout)
A timeout to wait if the index operation can't be performed immediately.
|
Modifier and Type | Method and Description |
---|---|
void |
BulkProcessor.Listener.afterBulk(long executionId,
BulkRequest request,
BulkResponse response)
Callback after a successful execution of bulk request.
|
void |
BulkProcessor.Listener.afterBulk(long executionId,
BulkRequest request,
Throwable failure)
Callback after a failed execution of bulk request.
|
void |
BulkProcessor.Listener.beforeBulk(long executionId,
BulkRequest request)
Callback before the bulk is executed.
|
protected void |
TransportBulkAction.doExecute(BulkRequest bulkRequest,
ActionListener<BulkResponse> listener) |
void |
TransportBulkAction.executeBulk(BulkRequest bulkRequest,
ActionListener<BulkResponse> listener)
This method executes the
BulkRequest and calls the given listener once the request returns. |
Modifier and Type | Method and Description |
---|---|
static BulkRequest |
Requests.bulkRequest()
Creats a new bulk request.
|
Modifier and Type | Method and Description |
---|---|
ActionFuture<BulkResponse> |
Client.bulk(BulkRequest request)
Executes a bulk of index / delete operations.
|
void |
Client.bulk(BulkRequest request,
ActionListener<BulkResponse> listener)
Executes a bulk of index / delete operations.
|
Modifier and Type | Method and Description |
---|---|
ActionFuture<BulkResponse> |
AbstractClient.bulk(BulkRequest request) |
void |
AbstractClient.bulk(BulkRequest request,
ActionListener<BulkResponse> listener) |
Modifier and Type | Method and Description |
---|---|
ActionFuture<BulkResponse> |
TransportClient.bulk(BulkRequest request) |
void |
TransportClient.bulk(BulkRequest request,
ActionListener<BulkResponse> listener) |
Copyright © 2009–2015. All rights reserved.