BaseRequestManager(AsyncClientInterface ots,
WriterConfig writerConfig,
BucketConfig bucketConfig,
Executor executor,
WriterHandleStatistics writerStatistics,
TableStoreCallback<RowChange,RowWriteResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
BatchWriteRowRequestManager(AsyncClientInterface ots,
WriterConfig writerConfig,
BucketConfig bucketConfig,
Executor executor,
WriterHandleStatistics writerStatistics,
TableStoreCallback<RowChange,RowWriteResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
BulkImportRequestManager(AsyncClientInterface ots,
WriterConfig writerConfig,
BucketConfig bucketConfig,
Executor executor,
WriterHandleStatistics writerStatistics,
TableStoreCallback<RowChange,RowWriteResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
FlushCallbackFactory(AsyncClientInterface ots,
Semaphore callbackSemaphore,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
WriterHandleStatistics writerStatistics,
BucketConfig bucketConfig,
Semaphore bucketSemaphore) |
RowEventHandler(AsyncClientInterface ots,
BucketConfig bucketConfig,
WriterConfig writerConfig,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
WriterHandleStatistics writerStatistics,
Semaphore semaphore) |