Flush
+ run():void
Builder
+ setConcurrentRequest(int concurrentRequest):Builder+ setBulkAction(int bulkActions):Builder+ setBulkSize(ByteSizeValue sizeValue):Builder+setFlushInterval(TimeValue flushInterval):Builder+ setBackoffPolicy(BackoffPolicy backoffPolicy):Builder+ setGlobalIndex(String index):Builder+ setGlobalType(String globalType):Builder+ setGlobalRouting(String globalRouting):Builder+ setGlobalPipeline(String globalPipeline):Builder+ build():BulkProcessor
Listener
Scheduler
+
BulkProcessor
- bulkAction:int- bulkSize:int- cancellableFlushTask:Scheduler- executionIdGen:AtomicLong- bulkRequest:BulkRequest- bulkRequestSupplier:Supplier<BulkRequest>- bulkRequestHandler:BulkRequestHandler- closed:Boolean
Closeable
+ close():void
Runnable
