本文整理了Java中com.palantir.atlasdb.transaction.api.Transaction.getRange()
方法的一些代码示例,展示了Transaction.getRange()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Transaction.getRange()
方法的具体详情如下:
包路径:com.palantir.atlasdb.transaction.api.Transaction
类名称: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);
}
});
}
内容来源于网络,如有侵权,请联系作者删除!