public class BatchWriteRowRequestManager extends BaseRequestManager
allowDuplicatedRowInBatchRequest, bucketConfig, bucketSemaphore, callback, callbackFactory, callbackSemaphore, executor, ots, rowChangeWithGroups, sendingPrimarykeys, totalRowsCount, totalSize, writerConfig, writerStatistics
构造器和说明 |
---|
BatchWriteRowRequestManager(AsyncClientInterface ots,
WriterConfig writerConfig,
BucketConfig bucketConfig,
Executor executor,
WriterHandleStatistics writerStatistics,
TableStoreCallback<RowChange,RowWriteResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
限定符和类型 | 方法和说明 |
---|---|
RequestWithGroups |
makeRequest() |
void |
sendRequest(RequestWithGroups requestWithGroups) |
appendRowChange, clear, getTotalRowsCount
public BatchWriteRowRequestManager(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 © 2021. All Rights Reserved.