| Modifier and Type | Method and Description |
|---|---|
BulkImportResponse |
SyncClientInterface.bulkImport(BulkImportRequest bulkImportRequest)
单张表中对多行执行更新或者删除操作,离线服务接口。
|
BulkImportResponse |
SyncClient.bulkImport(BulkImportRequest bulkImportRequest) |
Future<BulkImportResponse> |
AsyncClient.bulkImport(BulkImportRequest request,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback) |
Future<BulkImportResponse> |
InternalClient.bulkImport(BulkImportRequest request,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback) |
Future<BulkImportResponse> |
AsyncClientInterface.bulkImport(BulkImportRequest bulkImportRequest,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback)
在单张表中对多行执行更新或者删除操作,离线服务接口。
|
| Modifier and Type | Method and Description |
|---|---|
Future<BulkImportResponse> |
AsyncClient.bulkImport(BulkImportRequest request,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback) |
Future<BulkImportResponse> |
InternalClient.bulkImport(BulkImportRequest request,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback) |
Future<BulkImportResponse> |
AsyncClientInterface.bulkImport(BulkImportRequest bulkImportRequest,
TableStoreCallback<BulkImportRequest,BulkImportResponse> callback)
在单张表中对多行执行更新或者删除操作,离线服务接口。
|
| Modifier and Type | Method and Description |
|---|---|
BulkImportRequest |
BulkImportLauncher.getRequestForRetry(Exception e) |
| Modifier and Type | Method and Description |
|---|---|
BulkImportLauncher |
LauncherFactory.bulkImport(TraceLogger tracer,
RetryStrategy retry,
BulkImportRequest originRequest) |
void |
BulkImportLauncher.fire(BulkImportRequest req,
org.apache.http.concurrent.FutureCallback<BulkImportResponse> cb) |
| Constructor and Description |
|---|
BulkImportLauncher(OTSUri uri,
TraceLogger tracer,
RetryStrategy retry,
String instanceName,
AsyncServiceClient client,
CredentialsProvider crdsProvider,
ClientConfiguration config,
BulkImportRequest originRequest) |
| Modifier and Type | Method and Description |
|---|---|
static OtsInternalApi.BulkImportRequest |
OTSProtocolBuilder.buildBulkImportRequest(BulkImportRequest request) |
| Modifier and Type | Method and Description |
|---|---|
BulkImportRequest |
BulkImportRequest.createRequestForRetry(List<BulkImportResponse.RowResult> failedRows)
通过一次BulkImportRequest的返回结果,生成一个新的BulkImportRequest
|
Copyright © 2024. All Rights Reserved.