程序包 | 说明 |
---|---|
com.aliyun.openservices.ots | |
com.aliyun.openservices.ots.model | |
com.aliyun.openservices.ots.utils |
限定符和类型 | 方法和说明 |
---|---|
com.aliyun.openservices.ots.internal.OTSCallback<RowChange,ConsumedCapacity> |
OTSWriter.getCallback()
获取设置的Callback。
|
com.aliyun.openservices.ots.internal.OTSCallback<RowChange,ConsumedCapacity> |
DefaultOTSWriter.getCallback() |
限定符和类型 | 方法和说明 |
---|---|
void |
OTSWriter.addRowChange(RowChange rowChange)
向本地缓冲区增加一行数据。
|
void |
DefaultOTSWriter.addRowChange(RowChange rowChange) |
限定符和类型 | 方法和说明 |
---|---|
void |
OTSWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows)
向本地缓冲区批量写入行。
|
void |
OTSWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows)
向本地缓冲区批量写入行。
|
void |
DefaultOTSWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows) |
void |
DefaultOTSWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows) |
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) |
限定符和类型 | 类和说明 |
---|---|
class |
RowDeleteChange
表示数据行的删除信息。
|
class |
RowPutChange
表示行的插入或更新信息。
|
class |
RowUpdateChange
表示行的插入或更新信息。
|
限定符和类型 | 方法和说明 |
---|---|
void |
BatchWriteRowRequest.addRowChange(RowChange rowChange) |
限定符和类型 | 方法和说明 |
---|---|
static void |
ParamChecker.checkRowChange(TableMeta tableMeta,
RowChange rowChange,
com.aliyun.openservices.ots.internal.writer.WriterConfig config)
It does following checkings:
- primary key schema is matched with which defined in table meta
|
Copyright © 2016. All Rights Reserved.