UML-study

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