限定符和类型 | 方法和说明 |
---|---|
BulkImportResponse |
SyncClient.bulkImport(BulkImportRequest bulkImportRequest) |
BulkImportResponse |
SyncClientInterface.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)
在单张表中对多行执行更新或者删除操作,离线服务接口。
|
限定符和类型 | 方法和说明 |
---|---|
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)
在单张表中对多行执行更新或者删除操作,离线服务接口。
|
限定符和类型 | 方法和说明 |
---|---|
BulkImportRequest |
BulkImportLauncher.getRequestForRetry(Exception e) |
限定符和类型 | 方法和说明 |
---|---|
BulkImportLauncher |
LauncherFactory.bulkImport(TraceLogger tracer,
RetryStrategy retry,
BulkImportRequest originRequest) |
void |
BulkImportLauncher.fire(BulkImportRequest req,
org.apache.http.concurrent.FutureCallback<BulkImportResponse> cb) |
构造器和说明 |
---|
BulkImportLauncher(OTSUri uri,
TraceLogger tracer,
RetryStrategy retry,
String instanceName,
AsyncServiceClient client,
CredentialsProvider crdsProvider,
ClientConfiguration config,
BulkImportRequest originRequest) |
限定符和类型 | 方法和说明 |
---|---|
static OtsInternalApi.BulkImportRequest |
OTSProtocolBuilder.buildBulkImportRequest(BulkImportRequest request) |
限定符和类型 | 方法和说明 |
---|---|
BulkImportRequest |
BulkImportRequest.createRequestForRetry(List<BulkImportResponse.RowResult> failedRows)
通过一次BulkImportRequest的返回结果,生成一个新的BulkImportRequest
|
Copyright © 2019. All Rights Reserved.