public class BatchWriteRowRequest extends TxnRequest
| Constructor and Description |
|---|
BatchWriteRowRequest() |
| Modifier and Type | Method and Description |
|---|---|
void |
addRowChange(RowChange rowChange)
添加某个表的写操作参数。
|
BatchWriteRowRequest |
createRequestForRetry(List<BatchWriteRowResponse.RowResult> failedRows)
根据请求返回的结果,提取执行失败的行重新构造一次新的请求。
|
String |
getOperationName() |
Map<String,List<RowChange>> |
getRowChange()
获取所有表的操作参数。
|
RowChange |
getRowChange(String tableName,
int index)
根据表名和索引返回一次写操作的参数。
BatchWriteRowResult中返回的多行结果允许部分成功部分失败,返回结果按表组织,且表内行的顺序与BatchWriteRowRequest中一一对应。
若用户需要对BatchWriteRowResult中部分失败的行进行重试,则可以根据失败的行所在的表的表名以及在其在返回结果列表内的索引,从BatchWriteRowRequest中反查即可得到请求参数。
|
int |
getRowsCount()
获取该BatchWriteRow请求中包含的总的行数。
|
boolean |
isAtomic()
检查是否为批量原子写。
|
boolean |
isAtomicSet()
是否设置了批量原子写选项。
|
boolean |
isEmpty() |
void |
setAtomic(boolean atomic)
设置是否为批量原子写。
如果启用了批量原子写,需要保证写入到同一张表格中的分区键相同,否则会写入失败。
|
getTransactionId, hasSetTransactionId, setTransactionIdgetExtension, setExtensionpublic String getOperationName()
public void addRowChange(RowChange rowChange)
rowChange - 一次写操作的参数,操作类型可以是Put、Update、Delete,如果使用Txn,则每次BatchWriteRow只能允许单张表。public RowChange getRowChange(String tableName, int index)
tableName - 表的名称index - 该行在参数列表中得索引public BatchWriteRowRequest createRequestForRetry(List<BatchWriteRowResponse.RowResult> failedRows)
failedRows - 执行写操作失败的行public boolean isEmpty()
public int getRowsCount()
public boolean isAtomicSet()
public void setAtomic(boolean atomic)
atomic - 是否为批量原子写public boolean isAtomic()
Copyright © 2024. All Rights Reserved.