public class BulkImportRequestManager extends BaseRequestManager
allowDuplicatedRowInBatchRequest, bucketConfig, bucketSemaphore, callback, callbackFactory, callbackSemaphore, executor, ots, rowChangeWithGroups, sendingPrimarykeys, totalRowsCount, totalSize, writerConfig, writerStatistics| Constructor and Description |
|---|
BulkImportRequestManager(AsyncClientInterface ots,
WriterConfig writerConfig,
BucketConfig bucketConfig,
Executor executor,
WriterHandleStatistics writerStatistics,
TableStoreCallback<RowChange,RowWriteResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
| Modifier and Type | Method and Description |
|---|---|
RequestWithGroups |
makeRequest() |
void |
sendRequest(RequestWithGroups requestWithGroups) |
appendRowChange, clear, getTotalRowsCountpublic BulkImportRequestManager(AsyncClientInterface ots, WriterConfig writerConfig, BucketConfig bucketConfig, Executor executor, WriterHandleStatistics writerStatistics, TableStoreCallback<RowChange,RowWriteResult> callback, Semaphore callbackSemaphore, Semaphore bucketSemaphore)
public RequestWithGroups makeRequest()
public void sendRequest(RequestWithGroups requestWithGroups)
Copyright © 2024. All Rights Reserved.