void function ( ) { this . accumulator . flush ( ) ; }
flushes all pending writes concode_field_sep boolean running concode_elem_sep WriteResponseMapper<RecordMetadata> WRITE_RESPONSE_WRAPPER concode_elem_sep ExecutorService service concode_elem_sep BatchAccumulator<D> accumulator concode_elem_sep long startTime concode_elem_sep BatchAsyncDataWriter<D> writer concode_elem_sep RecordProcessor<D> processor concode_elem_sep Logger LOG concode_field_sep WriteCallback createBatchCallback concode_elem_sep void forceClose concode_elem_sep void run concode_elem_sep WriteResponse wrap concode_elem_sep void close concode_elem_sep void close concode_elem_sep Future<WriteResponse> write