|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use BulkProcessor.Builder | |
---|---|
org.elasticsearch.action.bulk |
Uses of BulkProcessor.Builder in org.elasticsearch.action.bulk |
---|
Methods in org.elasticsearch.action.bulk that return BulkProcessor.Builder | |
---|---|
static BulkProcessor.Builder |
BulkProcessor.builder(Client client,
BulkProcessor.Listener listener)
|
BulkProcessor.Builder |
BulkProcessor.Builder.setBulkActions(int bulkActions)
Sets when to flush a new bulk request based on the number of actions currently added. |
BulkProcessor.Builder |
BulkProcessor.Builder.setBulkSize(ByteSizeValue bulkSize)
Sets when to flush a new bulk request based on the size of actions currently added. |
BulkProcessor.Builder |
BulkProcessor.Builder.setConcurrentRequests(int concurrentRequests)
Sets the number of concurrent requests allowed to be executed. |
BulkProcessor.Builder |
BulkProcessor.Builder.setFlushInterval(TimeValue flushInterval)
Sets a flush interval flushing *any* bulk actions pending if the interval passes. |
BulkProcessor.Builder |
BulkProcessor.Builder.setName(String name)
Sets an optional name to identify this bulk processor. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |