public class BatchWriteRowRequest extends Object
构造器和说明 |
---|
BatchWriteRowRequest() |
限定符和类型 | 方法和说明 |
---|---|
void |
addRowChange(RowChange rowChange) |
void |
addRowDeleteChange(RowDeleteChange rowDeleteChange)
添加某个表的DeleteRow参数。
|
void |
addRowPutChange(RowPutChange rowPutChange)
添加某个表的PutRow参数。
|
void |
addRowUpdateChange(RowUpdateChange rowUpdateChange)
添加某个表的UpdateRow参数。
|
BatchWriteRowRequest |
createRequestForRetry(List<BatchWriteRowResult.RowStatus> failedRowsToPut,
List<BatchWriteRowResult.RowStatus> failedRowsToUpdate,
List<BatchWriteRowResult.RowStatus> failedRowsToDelete)
根据请求返回的结果,提取执行失败的行重新构造一次新的请求。
|
Map<String,List<RowDeleteChange>> |
getRowDeleteChange()
获取所有表的DeleteRow参数。
|
RowDeleteChange |
getRowDeleteChange(String tableName,
int index)
根据表名和索引返回DeleteRow参数。
|
Map<String,List<RowPutChange>> |
getRowPutChange()
获取所有表的PutRow参数。
|
RowPutChange |
getRowPutChange(String tableName,
int index)
根据表名和索引返回PutRow参数。
|
int |
getRowsCount()
获取该BatchWriteRow请求中包含的总的行数。
|
Map<String,List<RowUpdateChange>> |
getRowUpdateChange()
获取所有表的UpdateRow参数。
|
RowUpdateChange |
getRowUpdateChange(String tableName,
int index)
根据表名和索引返回UpdateRow参数。
|
boolean |
isEmpty()
检查BatchWriteRowRequest是否包含行。
|
public void addRowPutChange(RowPutChange rowPutChange)
rowPutChange
- PutRow参数public RowPutChange getRowPutChange(String tableName, int index)
tableName
- 表的名称index
- 该行在参数列表中得索引public Map<String,List<RowPutChange>> getRowPutChange()
public void addRowChange(RowChange rowChange)
public void addRowUpdateChange(RowUpdateChange rowUpdateChange)
rowUpdateChange
- UpdateRow参数public RowUpdateChange getRowUpdateChange(String tableName, int index)
tableName
- 表的名称index
- 该行在参数列表中得索引public Map<String,List<RowUpdateChange>> getRowUpdateChange()
public void addRowDeleteChange(RowDeleteChange rowDeleteChange)
rowDeleteChange
- DeleteRow参数public RowDeleteChange getRowDeleteChange(String tableName, int index)
tableName
- 表的名称index
- 该行在参数列表中得索引public Map<String,List<RowDeleteChange>> getRowDeleteChange()
public boolean isEmpty()
public int getRowsCount()
public BatchWriteRowRequest createRequestForRetry(List<BatchWriteRowResult.RowStatus> failedRowsToPut, List<BatchWriteRowResult.RowStatus> failedRowsToUpdate, List<BatchWriteRowResult.RowStatus> failedRowsToDelete)
failedRowsToPut
- 执行PutRow操作失败的行failedRowsToUpdate
- 执行UpdateRow操作失败的行failedRowsToDelete
- 执行DeleteRow操作失败的行Copyright © 2016. All Rights Reserved.