程序包 | 说明 |
---|---|
com.aliyun.openservices.ots | |
com.aliyun.openservices.ots.auth | |
com.aliyun.openservices.ots.comm | |
com.aliyun.openservices.ots.model | |
com.aliyun.openservices.ots.utils |
限定符和类型 | 方法和说明 |
---|---|
void |
OTSWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows)
向本地缓冲区批量写入行。
|
void |
DefaultOTSWriter.addRowChange(List<RowChange> rowChanges,
List<RowChange> dirtyRows) |
void |
OTSWriter.addRowChange(RowChange rowChange)
向本地缓冲区增加一行数据。
|
OTSFuture<BatchGetRowResult> |
OTSClientAsync.batchGetRow(BatchGetRowRequest batchGetRowRequest) |
BatchGetRowResult |
OTSClient.batchGetRow(BatchGetRowRequest batchGetRowRequest) |
OTSFuture<BatchGetRowResult> |
OTSAsync.batchGetRow(BatchGetRowRequest batchGetRowRequest)
从多张表(Table)中获取多行数据。
|
BatchGetRowResult |
OTS.batchGetRow(BatchGetRowRequest batchGetRowRequest)
从多张表(Table)中获取多行数据。
|
OTSFuture<BatchGetRowResult> |
OTSClientAsync.batchGetRow(BatchGetRowRequest batchGetRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<BatchGetRowRequest,BatchGetRowResult> callback) |
OTSFuture<BatchGetRowResult> |
OTSAsync.batchGetRow(BatchGetRowRequest batchGetRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<BatchGetRowRequest,BatchGetRowResult> callback)
从多张表(Table)中获取多行数据。
|
OTSFuture<BatchWriteRowResult> |
OTSClientAsync.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest) |
BatchWriteRowResult |
OTSClient.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest) |
OTSFuture<BatchWriteRowResult> |
OTSAsync.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest)
对多张表(Table)中的多行数据进行增加、删除或者更改操作。
|
BatchWriteRowResult |
OTS.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest)
对多张表(Table)中的多行数据进行增加、删除或者更改操作。
|
OTSFuture<BatchWriteRowResult> |
OTSClientAsync.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<BatchWriteRowRequest,BatchWriteRowResult> callback) |
OTSFuture<BatchWriteRowResult> |
OTSAsync.batchWriteRow(BatchWriteRowRequest batchWriteRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<BatchWriteRowRequest,BatchWriteRowResult> callback)
对多张表(Table)中的多行数据进行增加、删除或者更改操作。
|
Iterator<Row> |
OTSClient.createRangeIterator(RangeIteratorParameter rangeIteratorParameter) |
Iterator<Row> |
OTS.createRangeIterator(RangeIteratorParameter rangeIteratorParameter)
从表(Table)中迭代读取满足条件的数据
|
OTSFuture<CreateTableResult> |
OTSClientAsync.createTable(CreateTableRequest createTableRequest) |
CreateTableResult |
OTSClient.createTable(CreateTableRequest createTableRequest) |
OTSFuture<CreateTableResult> |
OTSAsync.createTable(CreateTableRequest createTableRequest)
创建表(Table)。
|
CreateTableResult |
OTS.createTable(CreateTableRequest createTableRequest)
创建表(Table)。
|
OTSFuture<CreateTableResult> |
OTSClientAsync.createTable(CreateTableRequest createTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<CreateTableRequest,CreateTableResult> callback) |
OTSFuture<CreateTableResult> |
OTSAsync.createTable(CreateTableRequest createTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<CreateTableRequest,CreateTableResult> callback)
创建表(Table)。
|
OTSFuture<DeleteRowResult> |
OTSClientAsync.deleteRow(DeleteRowRequest deleteRowRequest) |
DeleteRowResult |
OTSClient.deleteRow(DeleteRowRequest deleteRowRequest) |
OTSFuture<DeleteRowResult> |
OTSAsync.deleteRow(DeleteRowRequest deleteRowRequest)
删除表(Table)中的一行数据。
|
DeleteRowResult |
OTS.deleteRow(DeleteRowRequest deleteRowRequest)
删除表(Table)中的一行数据。
|
OTSFuture<DeleteRowResult> |
OTSClientAsync.deleteRow(DeleteRowRequest deleteRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<DeleteRowRequest,DeleteRowResult> callback) |
OTSFuture<DeleteRowResult> |
OTSAsync.deleteRow(DeleteRowRequest deleteRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<DeleteRowRequest,DeleteRowResult> callback)
删除表(Table)中的一行数据。
|
OTSFuture<DeleteTableResult> |
OTSClientAsync.deleteTable(DeleteTableRequest deleteTableRequest) |
DeleteTableResult |
OTSClient.deleteTable(DeleteTableRequest deleteTableRequest) |
OTSFuture<DeleteTableResult> |
OTSAsync.deleteTable(DeleteTableRequest deleteTableRequest)
删除表(Table)。
|
DeleteTableResult |
OTS.deleteTable(DeleteTableRequest deleteTableRequest)
删除表(Table)。
|
OTSFuture<DeleteTableResult> |
OTSClientAsync.deleteTable(DeleteTableRequest deleteTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<DeleteTableRequest,DeleteTableResult> callback) |
OTSFuture<DeleteTableResult> |
OTSAsync.deleteTable(DeleteTableRequest deleteTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<DeleteTableRequest,DeleteTableResult> callback)
删除表(Table)。
|
OTSFuture<DescribeTableResult> |
OTSClientAsync.describeTable(DescribeTableRequest describeTableRequest) |
DescribeTableResult |
OTSClient.describeTable(DescribeTableRequest describeTableRequest) |
OTSFuture<DescribeTableResult> |
OTSAsync.describeTable(DescribeTableRequest describeTableRequest)
返回表(Table)的结构信息。
|
DescribeTableResult |
OTS.describeTable(DescribeTableRequest describeTableRequest)
返回表(Table)的结构信息。
|
OTSFuture<DescribeTableResult> |
OTSClientAsync.describeTable(DescribeTableRequest describeTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<DescribeTableRequest,DescribeTableResult> callback) |
OTSFuture<DescribeTableResult> |
OTSAsync.describeTable(DescribeTableRequest describeTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<DescribeTableRequest,DescribeTableResult> callback)
返回表(Table)的结构信息。
|
void |
OTSWriter.flush()
主动flush缓冲区中的数据,该函数会等待缓冲区中的所有数据被flush完毕。
|
void |
DefaultOTSWriter.flush() |
OTSFuture<GetRangeResult> |
OTSClientAsync.getRange(GetRangeRequest getRangeRequest) |
GetRangeResult |
OTSClient.getRange(GetRangeRequest getRangeRequest) |
OTSFuture<GetRangeResult> |
OTSAsync.getRange(GetRangeRequest getRangeRequest)
从表(Table)中查询一个范围内的多行数据。
|
GetRangeResult |
OTS.getRange(GetRangeRequest getRangeRequest)
从表(Table)中查询一个范围内的多行数据。
|
OTSFuture<GetRangeResult> |
OTSClientAsync.getRange(GetRangeRequest getRangeRequest,
com.aliyun.openservices.ots.internal.OTSCallback<GetRangeRequest,GetRangeResult> callback) |
OTSFuture<GetRangeResult> |
OTSAsync.getRange(GetRangeRequest getRangeRequest,
com.aliyun.openservices.ots.internal.OTSCallback<GetRangeRequest,GetRangeResult> callback)
从表(Table)中查询一个范围内的多行数据。
|
OTSFuture<GetRowResult> |
OTSClientAsync.getRow(GetRowRequest getRowRequest) |
GetRowResult |
OTSClient.getRow(GetRowRequest getRowRequest) |
OTSFuture<GetRowResult> |
OTSAsync.getRow(GetRowRequest getRowRequest)
返回表(Table)中的一行数据。
|
GetRowResult |
OTS.getRow(GetRowRequest getRowRequest)
返回表(Table)中的一行数据。
|
OTSFuture<GetRowResult> |
OTSClientAsync.getRow(GetRowRequest getRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<GetRowRequest,GetRowResult> callback) |
OTSFuture<GetRowResult> |
OTSAsync.getRow(GetRowRequest getRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<GetRowRequest,GetRowResult> callback)
返回表(Table)中的一行数据。
|
OTSFuture<ListTableResult> |
OTSClientAsync.listTable() |
ListTableResult |
OTSClient.listTable() |
OTSFuture<ListTableResult> |
OTSAsync.listTable()
返回表(Table)名的列表。
|
ListTableResult |
OTS.listTable()
返回表(Table)名的列表。
|
OTSFuture<ListTableResult> |
OTSClientAsync.listTable(com.aliyun.openservices.ots.internal.OTSCallback<ListTableRequest,ListTableResult> callback) |
OTSFuture<ListTableResult> |
OTSAsync.listTable(com.aliyun.openservices.ots.internal.OTSCallback<ListTableRequest,ListTableResult> callback)
返回表(Table)名的列表。
|
OTSFuture<PutRowResult> |
OTSClientAsync.putRow(PutRowRequest putRowRequest) |
PutRowResult |
OTSClient.putRow(PutRowRequest putRowRequest) |
OTSFuture<PutRowResult> |
OTSAsync.putRow(PutRowRequest putRowRequest)
向表(Table)中插入或覆盖一行数据。
|
PutRowResult |
OTS.putRow(PutRowRequest putRowRequest)
向表(Table)中插入或覆盖一行数据。
|
OTSFuture<PutRowResult> |
OTSClientAsync.putRow(PutRowRequest putRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<PutRowRequest,PutRowResult> callback) |
OTSFuture<PutRowResult> |
OTSAsync.putRow(PutRowRequest putRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<PutRowRequest,PutRowResult> callback)
向表(Table)中插入或覆盖一行数据。
|
OTSFuture<UpdateRowResult> |
OTSClientAsync.updateRow(UpdateRowRequest updateRowRequest) |
UpdateRowResult |
OTSClient.updateRow(UpdateRowRequest updateRowRequest) |
OTSFuture<UpdateRowResult> |
OTSAsync.updateRow(UpdateRowRequest updateRowRequest)
更改表(Table)中的一行数据。
|
UpdateRowResult |
OTS.updateRow(UpdateRowRequest updateRowRequest)
更改表(Table)中的一行数据。
|
OTSFuture<UpdateRowResult> |
OTSClientAsync.updateRow(UpdateRowRequest updateRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<UpdateRowRequest,UpdateRowResult> callback) |
OTSFuture<UpdateRowResult> |
OTSAsync.updateRow(UpdateRowRequest updateRowRequest,
com.aliyun.openservices.ots.internal.OTSCallback<UpdateRowRequest,UpdateRowResult> callback)
更改表(Table)中的一行数据。
|
OTSFuture<UpdateTableResult> |
OTSClientAsync.updateTable(UpdateTableRequest updateTableRequest) |
UpdateTableResult |
OTSClient.updateTable(UpdateTableRequest updateTableRequest) |
OTSFuture<UpdateTableResult> |
OTSAsync.updateTable(UpdateTableRequest updateTableRequest)
更新表的读或写CapacityUnit。
|
UpdateTableResult |
OTS.updateTable(UpdateTableRequest updateTableRequest)
更新表的读或写CapacityUnit。
|
OTSFuture<UpdateTableResult> |
OTSClientAsync.updateTable(UpdateTableRequest updateTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<UpdateTableRequest,UpdateTableResult> callback) |
OTSFuture<UpdateTableResult> |
OTSAsync.updateTable(UpdateTableRequest updateTableRequest,
com.aliyun.openservices.ots.internal.OTSCallback<UpdateTableRequest,UpdateTableResult> callback)
更新表的读或写CapacityUnit。
|
限定符和类型 | 方法和说明 |
---|---|
void |
RequestSigner.sign(RequestMessage request) |
限定符和类型 | 方法和说明 |
---|---|
void |
RequestHandler.handle(RequestMessage message)
预处理需要发送的请求数据
|
void |
ResponseHandler.handle(ResponseMessage responseData)
处理返回的结果
|
protected void |
ServiceClient.handleRequest(RequestMessage message,
List<RequestHandler> resquestHandlers) |
限定符和类型 | 方法和说明 |
---|---|
V |
OTSFuture.get() |
T |
OTSBasicFuture.get() |
V |
OTSFuture.get(long timeout,
TimeUnit unit) |
T |
OTSBasicFuture.get(long timeout,
TimeUnit unit) |
Map<String,ColumnValue> |
Row.getColumns()
获取列(Column)名称与值的只读对应字典。
|
SortedMap<String,ColumnValue> |
Row.getSortedColumns()
获取列(Column)名称与值的只读对应字典,字典中的列按名称进行排序。
|
限定符和类型 | 方法和说明 |
---|---|
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.