限定符和类型 | 方法和说明 |
---|---|
TableStoreCallback<RowChange,ConsumedCapacity> |
DefaultTableStoreWriter.getCallback() |
TableStoreCallback<RowChange,ConsumedCapacity> |
TableStoreWriter.getCallback()
已过时。
please change to
TableStoreWriter.getResultCallback() |
TableStoreCallback<RowChange,RowWriteResult> |
DefaultTableStoreWriter.getResultCallback() |
TableStoreCallback<RowChange,RowWriteResult> |
TableStoreWriter.getResultCallback()
获取设置的Callback。
|
限定符和类型 | 方法和说明 |
---|---|
void |
DefaultTableStoreWriter.addRowChange(RowChange rowChange) |
void |
TableStoreWriter.addRowChange(RowChange rowChange)
向本地缓冲区增加一行数据。
|
boolean |
DefaultTableStoreWriter.addRowChangeInternal(RowChange rowChange) |
boolean |
DefaultTableStoreWriter.tryAddRowChange(RowChange rowChange) |
boolean |
TableStoreWriter.tryAddRowChange(RowChange rowChange)
Same with
TableStoreWriter.addRowChange(RowChange) , but it won't be blocked if the buffer is full. |
限定符和类型 | 方法和说明 |
---|---|
void |
DefaultTableStoreWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows) |
void |
DefaultTableStoreWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows) |
void |
TableStoreWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows)
向本地缓冲区批量写入行。
|
void |
TableStoreWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows)
向本地缓冲区批量写入行。
|
void |
DefaultTableStoreWriter.setCallback(TableStoreCallback<RowChange,ConsumedCapacity> callback) |
void |
TableStoreWriter.setCallback(TableStoreCallback<RowChange,ConsumedCapacity> callback)
已过时。
please change to
TableStoreWriter.setResultCallback(TableStoreCallback) |
void |
DefaultTableStoreWriter.setResultCallback(TableStoreCallback<RowChange,RowWriteResult> resultCallback) |
void |
TableStoreWriter.setResultCallback(TableStoreCallback<RowChange,RowWriteResult> callback)
设置Callback,数据写入成功或者失败均会通过Callback来反馈。
|
构造器和说明 |
---|
DefaultTableStoreWriter(AsyncClientInterface ots,
String tableName,
WriterConfig config,
TableStoreCallback<RowChange,ConsumedCapacity> callback,
Executor executor) |
限定符和类型 | 方法和说明 |
---|---|
static void |
ParamChecker.checkRowChange(TableMeta tableMeta,
RowChange rowChange,
WriterConfig config)
It does following checkings:
- primary key schema is matched with which defined in table meta
|
限定符和类型 | 类和说明 |
---|---|
class |
RowDeleteChange |
class |
RowPutChange |
class |
RowUpdateChange |
限定符和类型 | 方法和说明 |
---|---|
RowChange |
BulkImportRequest.getRowChange(int index) |
RowChange |
BatchWriteRowRequest.getRowChange(String tableName,
int index)
根据表名和索引返回一次写操作的参数。
|
限定符和类型 | 方法和说明 |
---|---|
Map<String,List<RowChange>> |
BatchWriteRowRequest.getRowChange()
获取所有表的操作参数。
|
List<RowChange> |
BulkImportRequest.getRowChange() |
限定符和类型 | 方法和说明 |
---|---|
void |
BatchWriteRowRequest.addRowChange(RowChange rowChange)
添加某个表的写操作参数。
|
void |
BulkImportRequest.addRowChange(RowChange rowChange) |
限定符和类型 | 方法和说明 |
---|---|
void |
BulkImportRequest.addRowChanges(List<RowChange> rowChanges) |
限定符和类型 | 类和说明 |
---|---|
class |
RowPutChangeWithCallback |
构造器和说明 |
---|
TimestreamDBClient(AsyncClient asyncClient,
TimestreamDBConfiguration config,
WriterConfig writerConfig,
TableStoreCallback<RowChange,ConsumedCapacity> callback)
TimestreamDBClient的构造函数
|
限定符和类型 | 字段和说明 |
---|---|
RowChange |
RowChangeEvent.rowChange |
限定符和类型 | 方法和说明 |
---|---|
boolean |
WriteRPCBuffer.appendRowChange(RowChange rowChange)
向RPC缓冲中添加一个RowChange,若添加成功,返回true,否则返回false。
|
void |
RowChangeEvent.setValue(RowChange rowChange) |
限定符和类型 | 方法和说明 |
---|---|
void |
RowChangeEventHandler.setCallback(TableStoreCallback<RowChange,RowWriteResult> callback) |
构造器和说明 |
---|
RowChangeEventHandler(AsyncClientInterface ots,
WriterConfig writerConfig,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
DefaultWriterStatistics writerStatistics) |
Copyright © 2019. All Rights Reserved.