Package | Description |
---|---|
org.xbib.elasticsearch.action.websocket.bulk |
Modifier and Type | Method and Description |
---|---|
static BulkHandler.Builder |
BulkHandler.builder(org.elasticsearch.client.Client client,
BulkHandler.Listener listener) |
BulkHandler.Builder |
BulkHandler.Builder.setBulkActions(int bulkActions)
Sets when to flush a new bulk request based on the number of actions
currently added.
|
BulkHandler.Builder |
BulkHandler.Builder.setConcurrentRequests(int concurrentRequests)
Sets the number of concurrent requests allowed to be executed.
|
BulkHandler.Builder |
BulkHandler.Builder.setFlushInterval(org.elasticsearch.common.unit.TimeValue flushInterval)
Sets a flush interval flushing *any* bulk actions pending if the
interval passes.
|
Copyright © 2012–2014. All rights reserved.