void function ( ) { try { awaitClose ( 0 , TimeUnit . NANOSECONDS ) ; } catch ( InterruptedException loc0 ) { Thread . currentThread ( ) . interrupt ( ) ; } }
closes the processor . if flushing by time is enabled , then it 's shutdown . any remaining bulk actions are flushed . concode_field_sep ThreadPool.Cancellable cancellableFlushTask concode_elem_sep BulkRequestHandler bulkRequestHandler concode_elem_sep int concurrentRequests concode_elem_sep AtomicLong executionIdGen concode_elem_sep Listener listener concode_elem_sep int bulkActions concode_elem_sep long bulkSize concode_elem_sep int bulkActions concode_elem_sep BackoffPolicy backoffPolicy concode_elem_sep ThreadPool threadPool concode_elem_sep ByteSizeValue bulkSize concode_elem_sep BulkRequest bulkRequest concode_elem_sep TimeValue flushInterval concode_elem_sep BiConsumer<BulkRequest,ActionListener<BulkResponse>> consumer concode_elem_sep boolean closed concode_field_sep Builder setBulkSize concode_elem_sep Builder setFlushInterval concode_elem_sep BulkProcessor add concode_elem_sep BulkProcessor add concode_elem_sep BulkProcessor add concode_elem_sep BulkProcessor add concode_elem_sep BulkProcessor add concode_elem_sep BulkProcessor add concode_elem_sep void executeIfNeeded concode_elem_sep Builder setBulkActions concode_elem_sep void run concode_elem_sep void execute concode_elem_sep boolean isOverTheLimit concode_elem_sep void beforeBulk concode_elem_sep boolean isOpen concode_elem_sep void flush concode_elem_sep BulkProcessor build concode_elem_sep void afterBulk concode_elem_sep void afterBulk concode_elem_sep void ensureOpen concode_elem_sep Builder builder concode_elem_sep Builder setConcurrentRequests concode_elem_sep boolean awaitClose concode_elem_sep Builder setBackoffPolicy concode_elem_sep ThreadPool.Cancellable startFlushTask concode_elem_sep void internalAdd