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

Transaction.getRows介绍

暂无

代码示例

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

public Optional<LatestSnapshotRowResult> getRow(LatestSnapshotRow row, ColumnSelection columns) {
  byte[] bytes = row.persistToBytes();
  RowResult<byte[]> rowResult = t.getRows(tableRef, ImmutableSet.of(bytes), columns).get(bytes);
  if (rowResult == null) {
    return Optional.empty();
  } else {
    return Optional.of(LatestSnapshotRowResult.of(rowResult));
  }
}

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

@Override
public List<TodoRowResult> getRows(Iterable<TodoRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<TodoRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(TodoRowResult.of(row));
  }
  return rowResults;
}

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

public Optional<TableClearsRowResult> getRow(TableClearsRow row, ColumnSelection columns) {
  byte[] bytes = row.persistToBytes();
  RowResult<byte[]> rowResult = t.getRows(tableRef, ImmutableSet.of(bytes), columns).get(bytes);
  if (rowResult == null) {
    return Optional.empty();
  } else {
    return Optional.of(TableClearsRowResult.of(rowResult));
  }
}

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

@Override
public List<TableClearsRowResult> getRows(Iterable<TableClearsRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<TableClearsRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(TableClearsRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<UserPhotosStreamValueRowResult> getRows(Iterable<UserPhotosStreamValueRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<UserPhotosStreamValueRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(UserPhotosStreamValueRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<BlobsSerializableRowResult> getRows(Iterable<BlobsSerializableRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<BlobsSerializableRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(BlobsSerializableRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<UserPhotosStreamMetadataRowResult> getRows(Iterable<UserPhotosStreamMetadataRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<UserPhotosStreamMetadataRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(UserPhotosStreamMetadataRowResult.of(row));
  }
  return rowResults;
}

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

public Optional<MetadataRowResult> getRow(MetadataRow row, ColumnSelection columns) {
  byte[] bytes = row.persistToBytes();
  RowResult<byte[]> rowResult = t.getRows(tableRef, ImmutableSet.of(bytes), columns).get(bytes);
  if (rowResult == null) {
    return Optional.empty();
  } else {
    return Optional.of(MetadataRowResult.of(rowResult));
  }
}

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

@Override
public List<ValueStreamValueRowResult> getRows(Iterable<ValueStreamValueRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<ValueStreamValueRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(ValueStreamValueRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<HotspottyDataStreamMetadataRowResult> getRows(Iterable<HotspottyDataStreamMetadataRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<HotspottyDataStreamMetadataRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(HotspottyDataStreamMetadataRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<ValueStreamMetadataRowResult> getRows(Iterable<ValueStreamMetadataRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<ValueStreamMetadataRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(ValueStreamMetadataRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<CompactMetadataRowResult> getRows(Iterable<CompactMetadataRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<CompactMetadataRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(CompactMetadataRowResult.of(row));
  }
  return rowResults;
}

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

public Optional<UserPhotosStreamValueRowResult> getRow(UserPhotosStreamValueRow row, ColumnSelection columns) {
  byte[] bytes = row.persistToBytes();
  RowResult<byte[]> rowResult = t.getRows(tableRef, ImmutableSet.of(bytes), columns).get(bytes);
  if (rowResult == null) {
    return Optional.empty();
  } else {
    return Optional.of(UserPhotosStreamValueRowResult.of(rowResult));
  }
}

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

public Optional<RangeScanTestRowResult> getRow(RangeScanTestRow row, ColumnSelection columns) {
  byte[] bytes = row.persistToBytes();
  RowResult<byte[]> rowResult = t.getRows(tableRef, ImmutableSet.of(bytes), columns).get(bytes);
  if (rowResult == null) {
    return Optional.empty();
  } else {
    return Optional.of(RangeScanTestRowResult.of(rowResult));
  }
}

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

public Optional<StreamTestMaxMemStreamValueRowResult> getRow(StreamTestMaxMemStreamValueRow row, ColumnSelection columns) {
  byte[] bytes = row.persistToBytes();
  RowResult<byte[]> rowResult = t.getRows(tableRef, ImmutableSet.of(bytes), columns).get(bytes);
  if (rowResult == null) {
    return Optional.empty();
  } else {
    return Optional.of(StreamTestMaxMemStreamValueRowResult.of(rowResult));
  }
}

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

@Override
public List<StreamTestStreamValueRowResult> getRows(Iterable<StreamTestStreamValueRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<StreamTestStreamValueRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(StreamTestStreamValueRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<TestHashComponentsStreamMetadataRowResult> getRows(Iterable<TestHashComponentsStreamMetadataRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<TestHashComponentsStreamMetadataRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(TestHashComponentsStreamMetadataRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<StreamTestMaxMemStreamValueRowResult> getRows(Iterable<StreamTestMaxMemStreamValueRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<StreamTestMaxMemStreamValueRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(StreamTestMaxMemStreamValueRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<TwoColumnsRowResult> getRows(Iterable<TwoColumnsRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<TwoColumnsRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(TwoColumnsRowResult.of(row));
  }
  return rowResults;
}

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

@Override
public List<StreamTestWithHashStreamMetadataRowResult> getRows(Iterable<StreamTestWithHashStreamMetadataRow> rows, ColumnSelection columns) {
  SortedMap<byte[], RowResult<byte[]>> results = t.getRows(tableRef, Persistables.persistAll(rows), columns);
  List<StreamTestWithHashStreamMetadataRowResult> rowResults = Lists.newArrayListWithCapacity(results.size());
  for (RowResult<byte[]> row : results.values()) {
    rowResults.add(StreamTestWithHashStreamMetadataRowResult.of(row));
  }
  return rowResults;
}