表quota不足时,允许批量操作的部分操作执行


BatchResult partialAllowedBatch(BatchRequest request)

功能

一般的batch请求,当表quota不足时会全部拒绝;而partialAllowedBatch允许在quota满足的范围内,部分记录可以执行, 通过返回值告知用户哪些记录执行成功,哪些记录没有执行, 若当前quota不满足甚至1条记录执行,会抛出THROUGHPUT_EXCEED异常; 用户需要检查返回值,把没有执行的记录循环地发请求,直到所有记录都成功执行为止。

方法参数

request : BatchRequest : required

BatchRequest 包括一个可以为PutRequest, RemoveRequest, GetRequest, IncrementRequest的列表

1.items : List< BatchRequestItem > : required

BatchRequestItem包括BatchOp和Request

枚举类型BatchOp(PUT, GET, REMOVE, INCREMENT)指定该request的操作类型,

相应的,使用putRequest,getRequest, removeRequest,incrementRequest构造Request参数

方法返回值

batchResult : BatchResult

BatchResult 包括一个带有BatchResultItem的列表,表示batch的每个请求的执行结果

items : List< BatchResultItem >

返回每个子操作的结果,其中isSuccess==true表示已经执行,isSuccess==false表示没有执行

限制

每个子操作必须是同一个表的

put,remove请求不支持带条件

batch操作的子操作数范围为[ 1, 100 ]

示例

下面示例代码

List<BatchRequestItem> batch = new ArrayList<BatchRequestItem>();
  for (int i = 11; i < 20; i++) {
    BatchRequestItem item = new BatchRequestItem().setAction(BatchOp.PUT);
    Map<String, Datum> record = new HashMap<String, Datum>();
    record.put("cityId", DatumUtil.toDatum(cities[i]));
    putRequest.putToRecord("timestamp", DatumUtil.toDatum(now.getTime()));
    putRequest.putToRecord("score", DatumUtil.toDatum((double) new Random().nextInt(100)));
    putRequest.putToRecord("pm25", DatumUtil.toDatum((long) (new Random().nextInt(500))));
    item.setRequest(Request.putRequest(new PutRequest().setTableName(tableName).setRecord(record)));
    batch.add(item);
  }

  while (true) {
    BatchResult br = tableClient.partialAllowedBatch(new BatchRequest().setItems(batch));
    List<BatchRequestItem> request = new ArrayList<BatchRequestItem>();
    for (int i = 0; i < br.getItems().size(); i++) {
    //At current only quota exceeded will get  isSuccess() == false
      if (!br.getItems().get(i).isSuccess()) {
        request.add(batch.get(i));
      }
    }
    if (request.isEmpty()) {
      break;
    }
    Thread.sleep(100); // wait a while to retry.
    batch = request;
  }

results matching ""

    No results matching ""