com.palantir.atlasdb.transaction.api.Transaction.getRange()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(106)

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

Transaction.getRange介绍

[英]Creates a visitable that scans the provided range.
[中]创建扫描所提供范围的可见表。

代码示例

代码示例来源:origin: palantir/atlasdb

private List<RowResult<byte[]>> getRangeInner(ConsecutiveNarrowTable table) {
  final int rangeRequestSize = 1000;
  return table.getTransactionManager().runTaskThrowOnConflict(txn -> {
    RangeRequest request = Iterables.getOnlyElement(table.getRangeRequests(1, rangeRequestSize, false));
    List<RowResult<byte[]>> results = BatchingVisitables.copyToList(txn.getRange(
        table.getTableRef(), request));
    Preconditions.checkState(results.size() == rangeRequestSize,
        "Expected %s rows, found %s rows", rangeRequestSize, results.size());
    return results;
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<KeyValueRowResult> getRange(RangeRequest range) {
  if (range.getColumnNames().isEmpty()) {
    range = range.getBuilder().retainColumns(allColumns).build();
  }
  return BatchingVisitables.transform(t.getRange(tableRef, range), new Function<RowResult<byte[]>, KeyValueRowResult>() {
    @Override
    public KeyValueRowResult apply(RowResult<byte[]> input) {
      return KeyValueRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<CreatedIdxRowResult> getRange(RangeRequest range) {
  if (range.getColumnNames().isEmpty()) {
    range = range.getBuilder().retainColumns(allColumns).build();
  }
  return BatchingVisitables.transform(t.getRange(tableRef, range), new Function<RowResult<byte[]>, CreatedIdxRowResult>() {
    @Override
    public CreatedIdxRowResult apply(RowResult<byte[]> input) {
      return CreatedIdxRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<UserBirthdaysIdxRowResult> getRange(RangeRequest range) {
  if (range.getColumnNames().isEmpty()) {
    range = range.getBuilder().retainColumns(allColumns).build();
  }
  return BatchingVisitables.transform(t.getRange(tableRef, range), new Function<RowResult<byte[]>, UserBirthdaysIdxRowResult>() {
    @Override
    public UserBirthdaysIdxRowResult apply(RowResult<byte[]> input) {
      return UserBirthdaysIdxRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<KvRowsRowResult> getRange(RangeRequest range) {
  if (range.getColumnNames().isEmpty()) {
    range = range.getBuilder().retainColumns(allColumns).build();
  }
  return BatchingVisitables.transform(t.getRange(tableRef, range), new Function<RowResult<byte[]>, KvRowsRowResult>() {
    @Override
    public KvRowsRowResult apply(RowResult<byte[]> input) {
      return KvRowsRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<HotspottyDataStreamMetadataRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, HotspottyDataStreamMetadataRowResult>() {
    @Override
    public HotspottyDataStreamMetadataRowResult apply(RowResult<byte[]> input) {
      return HotspottyDataStreamMetadataRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<HotspottyDataStreamIdxRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, HotspottyDataStreamIdxRowResult>() {
    @Override
    public HotspottyDataStreamIdxRowResult apply(RowResult<byte[]> input) {
      return HotspottyDataStreamIdxRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<CheckAndSetRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, CheckAndSetRowResult>() {
    @Override
    public CheckAndSetRowResult apply(RowResult<byte[]> input) {
      return CheckAndSetRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<UserPhotosStreamIdxRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, UserPhotosStreamIdxRowResult>() {
    @Override
    public UserPhotosStreamIdxRowResult apply(RowResult<byte[]> input) {
      return UserPhotosStreamIdxRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<DataStreamMetadataRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, DataStreamMetadataRowResult>() {
    @Override
    public DataStreamMetadataRowResult apply(RowResult<byte[]> input) {
      return DataStreamMetadataRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<ValueStreamIdxRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, ValueStreamIdxRowResult>() {
    @Override
    public ValueStreamIdxRowResult apply(RowResult<byte[]> input) {
      return ValueStreamIdxRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<UserPhotosStreamValueRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, UserPhotosStreamValueRowResult>() {
    @Override
    public UserPhotosStreamValueRowResult apply(RowResult<byte[]> input) {
      return UserPhotosStreamValueRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<BlobsRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, BlobsRowResult>() {
    @Override
    public BlobsRowResult apply(RowResult<byte[]> input) {
      return BlobsRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<UserPhotosStreamMetadataRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, UserPhotosStreamMetadataRowResult>() {
    @Override
    public UserPhotosStreamMetadataRowResult apply(RowResult<byte[]> input) {
      return UserPhotosStreamMetadataRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<UserProfileRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, UserProfileRowResult>() {
    @Override
    public UserProfileRowResult apply(RowResult<byte[]> input) {
      return UserProfileRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<Index4IdxRowResult> getRange(RangeRequest range) {
  if (range.getColumnNames().isEmpty()) {
    range = range.getBuilder().retainColumns(allColumns).build();
  }
  return BatchingVisitables.transform(t.getRange(tableRef, range), new Function<RowResult<byte[]>, Index4IdxRowResult>() {
    @Override
    public Index4IdxRowResult apply(RowResult<byte[]> input) {
      return Index4IdxRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<KeyValueRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, KeyValueRowResult>() {
    @Override
    public KeyValueRowResult apply(RowResult<byte[]> input) {
      return KeyValueRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<StreamTestWithHashStreamValueRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, StreamTestWithHashStreamValueRowResult>() {
    @Override
    public StreamTestWithHashStreamValueRowResult apply(RowResult<byte[]> input) {
      return StreamTestWithHashStreamValueRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<StreamTestWithHashStreamIdxRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, StreamTestWithHashStreamIdxRowResult>() {
    @Override
    public StreamTestWithHashStreamIdxRowResult apply(RowResult<byte[]> input) {
      return StreamTestWithHashStreamIdxRowResult.of(input);
    }
  });
}

代码示例来源:origin: palantir/atlasdb

public BatchingVisitableView<StreamTestWithHashStreamMetadataRowResult> getAllRowsUnordered(ColumnSelection columns) {
  return BatchingVisitables.transform(t.getRange(tableRef, RangeRequest.builder().retainColumns(columns).build()),
      new Function<RowResult<byte[]>, StreamTestWithHashStreamMetadataRowResult>() {
    @Override
    public StreamTestWithHashStreamMetadataRowResult apply(RowResult<byte[]> input) {
      return StreamTestWithHashStreamMetadataRowResult.of(input);
    }
  });
}

相关文章