org.rocksdb.RocksDB.multiGet()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(275)

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

RocksDB.multiGet介绍

[英]Returns a map of keys for which values were found in DB.
[中]返回在DB中找到其值的键的映射。

代码示例

代码示例来源:origin: alibaba/jstorm

  1. Map<byte[], byte[]> results = db.multiGet(lookupKeys);
  2. if (results == null || results.size() == 0) {
  3. return;

代码示例来源:origin: org.rocksdb/rocksdbjni

  1. final byte[][] values = multiGet(nativeHandle_, opt.nativeHandle_,
  2. keysArray, keyOffsets, keyLengths);

代码示例来源:origin: com.alibaba.jstorm/jstorm-core

  1. Map<byte[], byte[]> results = db.multiGet(lookupKeys);
  2. if (results == null || results.size() == 0) {
  3. return;

代码示例来源:origin: org.rocksdb/rocksdbjni

  1. final byte[][] values = multiGet(nativeHandle_, keysArray, keyOffsets,
  2. keyLengths);

代码示例来源:origin: com.palantir.atlasdb/atlasdb-rocksdb

  1. @Override
  2. public Map<TableReference, byte[]> getMetadataForTables() {
  3. Set<String> tableNames = columnFamilies.getTableNames();
  4. List<ColumnFamilyHandle> tables = Lists.newArrayListWithCapacity(tableNames.size());
  5. List<byte[]> keys = Lists.newArrayListWithCapacity(tableNames.size());
  6. try (ColumnFamily metadataTable = columnFamilies.get(METADATA_TABLE_NAME.getQualifiedName())) {
  7. for (String tableName : tableNames) {
  8. tables.add(metadataTable.getHandle());
  9. keys.add(tableName.getBytes(Charsets.UTF_8));
  10. }
  11. Map<byte[], byte[]> rawResults = getDb().multiGet(tables, keys);
  12. Map<TableReference, byte[]> results = Maps.newHashMapWithExpectedSize(rawResults.size());
  13. for (Entry<byte[], byte[]> entry : rawResults.entrySet()) {
  14. results.put(TableReference.createUnsafe(new String(entry.getKey(), Charsets.UTF_8)), entry.getValue());
  15. }
  16. return results;
  17. } catch (RocksDBException e) {
  18. throw Throwables.propagate(e);
  19. }
  20. }

代码示例来源:origin: org.rocksdb/rocksdbjni

  1. final byte[][] values = multiGet(nativeHandle_, keysArray, keyOffsets,
  2. keyLengths, cfHandles);

代码示例来源:origin: org.rocksdb/rocksdbjni

  1. final byte[][] values = multiGet(nativeHandle_, opt.nativeHandle_,
  2. keysArray, keyOffsets, keyLengths, cfHandles);

代码示例来源:origin: locationtech/geowave

  1. public synchronized CloseableIterator<GeoWaveRow> dataIndexIterator(final byte[][] dataIds) {
  2. final RocksDB readDb = getReadDb();
  3. if (readDb == null) {
  4. return new CloseableIterator.Empty<>();
  5. }
  6. try {
  7. final List<byte[]> dataIdsList = Arrays.asList(dataIds);
  8. final Map<byte[], byte[]> dataIdxResults = readDb.multiGet(dataIdsList);
  9. return new CloseableIterator.Wrapper(
  10. dataIdsList.stream().map(
  11. dataId -> DataIndexUtils.deserializeDataIndexRow(
  12. dataId,
  13. adapterId,
  14. dataIdxResults.get(dataId),
  15. visibilityEnabled)).iterator());
  16. } catch (final RocksDBException e) {
  17. LOGGER.error("Unable to get values by data ID", e);
  18. }
  19. return new CloseableIterator.Empty<>();
  20. }
  21. }

相关文章