org.apache.hadoop.hbase.client.Append.isReturnResults()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(3.3k)|赞(0)|评价(0)|浏览(166)

本文整理了Java中org.apache.hadoop.hbase.client.Append.isReturnResults()方法的一些代码示例,展示了Append.isReturnResults()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Append.isReturnResults()方法的具体详情如下:
包路径:org.apache.hadoop.hbase.client.Append
类名称:Append
方法名:isReturnResults

Append.isReturnResults介绍

暂无

代码示例

代码示例来源:origin: apache/hbase

  1. public Result append(Append mutation, long nonceGroup, long nonce) throws IOException {
  2. return doDelta(Operation.APPEND, mutation, nonceGroup, nonce, mutation.isReturnResults());
  3. }

代码示例来源:origin: apache/hbase

  1. throw new RuntimeException(e);
  2. out.setReturnResults(in.isReturnResults());
  3. return out;

代码示例来源:origin: com.google.cloud.bigtable/bigtable-hbase-2.x

  1. /**
  2. * {@inheritDoc}
  3. */
  4. @Override
  5. public CompletableFuture<Result> append(Append append) {
  6. ReadModifyWriteRowRequest request = hbaseAdapter.adapt(append);
  7. Function<? super ReadModifyWriteRowResponse, ? extends Result> adaptRowFunction = response ->
  8. append.isReturnResults()
  9. ? Adapters.ROW_ADAPTER.adaptResponse(response.getRow())
  10. : null;
  11. return client.readModifyWriteRowAsync(request).thenApply(adaptRowFunction);
  12. }

代码示例来源:origin: GoogleCloudPlatform/cloud-bigtable-client

  1. /**
  2. * {@inheritDoc}
  3. */
  4. @Override
  5. public CompletableFuture<Result> append(Append append) {
  6. ReadModifyWriteRowRequest request = hbaseAdapter.adapt(append);
  7. Function<? super ReadModifyWriteRowResponse, ? extends Result> adaptRowFunction = response ->
  8. append.isReturnResults()
  9. ? Adapters.ROW_ADAPTER.adaptResponse(response.getRow())
  10. : null;
  11. return client.readModifyWriteRowAsync(request).thenApply(adaptRowFunction);
  12. }

代码示例来源:origin: co.cask.hbase/hbase

  1. return append.isReturnResults() ? new Result(allKVs) : null;

代码示例来源:origin: harbby/presto-connectors

  1. return mutate.isReturnResults() ? Result.create(allKVs) : null;

代码示例来源:origin: com.google.cloud.bigtable/bigtable-hbase

  1. /** {@inheritDoc} */
  2. @Override
  3. public Result append(Append append) throws IOException {
  4. LOG.trace("append(Append)");
  5. Span span = TRACER.spanBuilder("BigtableTable.append").startSpan();
  6. try (Scope scope = TRACER.withSpan(span)) {
  7. ReadModifyWriteRowRequest request = hbaseAdapter.adapt(append);
  8. ReadModifyWriteRowResponse response = client.readModifyWriteRow(request);
  9. // The bigtable API will always return the mutated results. In order to maintain
  10. // compatibility, simply return null when results were not requested.
  11. if (append.isReturnResults()) {
  12. return Adapters.ROW_ADAPTER.adaptResponse(response.getRow());
  13. } else {
  14. return null;
  15. }
  16. } catch (Throwable t) {
  17. span.setStatus(Status.UNKNOWN);
  18. throw logAndCreateIOException("append", append.getRow(), t);
  19. } finally {
  20. span.end();
  21. }
  22. }

代码示例来源:origin: GoogleCloudPlatform/cloud-bigtable-client

  1. /** {@inheritDoc} */
  2. @Override
  3. public Result append(Append append) throws IOException {
  4. LOG.trace("append(Append)");
  5. Span span = TRACER.spanBuilder("BigtableTable.append").startSpan();
  6. try (Scope scope = TRACER.withSpan(span)) {
  7. ReadModifyWriteRowRequest request = hbaseAdapter.adapt(append);
  8. ReadModifyWriteRowResponse response = client.readModifyWriteRow(request);
  9. // The bigtable API will always return the mutated results. In order to maintain
  10. // compatibility, simply return null when results were not requested.
  11. if (append.isReturnResults()) {
  12. return Adapters.ROW_ADAPTER.adaptResponse(response.getRow());
  13. } else {
  14. return null;
  15. }
  16. } catch (Throwable t) {
  17. span.setStatus(Status.UNKNOWN);
  18. throw logAndCreateIOException("append", append.getRow(), t);
  19. } finally {
  20. span.end();
  21. }
  22. }

相关文章