程序包 | 说明 |
---|---|
com.aliyun.openservices.ots | |
com.aliyun.openservices.ots.model |
限定符和类型 | 方法和说明 |
---|---|
com.aliyun.openservices.ots.internal.OTSCallback<RowChange,ConsumedCapacity> |
OTSWriter.getCallback()
获取设置的Callback。
|
com.aliyun.openservices.ots.internal.OTSCallback<RowChange,ConsumedCapacity> |
DefaultOTSWriter.getCallback() |
限定符和类型 | 方法和说明 |
---|---|
void |
OTSWriter.setCallback(com.aliyun.openservices.ots.internal.OTSCallback<RowChange,ConsumedCapacity> callback)
设置Callback,数据写入成功或者失败均会通过Callback来反馈。
|
void |
DefaultOTSWriter.setCallback(com.aliyun.openservices.ots.internal.OTSCallback<RowChange,ConsumedCapacity> callback) |
构造器和说明 |
---|
DefaultOTSWriter(OTSAsync ots,
String tableName,
com.aliyun.openservices.ots.internal.writer.WriterConfig config,
com.aliyun.openservices.ots.internal.OTSCallback<RowChange,ConsumedCapacity> callback,
Executor executor) |
限定符和类型 | 方法和说明 |
---|---|
ConsumedCapacity |
UpdateRowResult.getConsumedCapacity()
获取此次操作消耗的CapacityUnit。
|
ConsumedCapacity |
PutRowResult.getConsumedCapacity()
获取此次操作消耗的CapacityUnit。
|
ConsumedCapacity |
GetRowResult.getConsumedCapacity()
获取此次操作消耗的CapacityUnit。
|
ConsumedCapacity |
GetRangeResult.getConsumedCapacity()
获取此次操作消耗的CapacityUnit。
|
ConsumedCapacity |
DeleteRowResult.getConsumedCapacity() |
ConsumedCapacity |
BatchWriteRowResult.RowStatus.getConsumedCapacity() |
ConsumedCapacity |
BatchGetRowResult.RowStatus.getConsumedCapacity() |
static ConsumedCapacity |
OTSProtocolHelper.parseConsumedCapacity(OtsProtocol2.ConsumedCapacity consumed) |
限定符和类型 | 方法和说明 |
---|---|
void |
DeleteRowResult.setConsumedCapacity(ConsumedCapacity consumedCapacity) |
构造器和说明 |
---|
RowStatus(String tableName,
ConsumedCapacity consumedCapacity,
int index) |
RowStatus(String tableName,
Row row,
ConsumedCapacity consumedCapacity,
int index) |
Copyright © 2016. All Rights Reserved.