本文整理了Java中org.rocksdb.RocksDB.multiGet
方法的一些代码示例,展示了RocksDB.multiGet
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RocksDB.multiGet
方法的具体详情如下:
包路径:org.rocksdb.RocksDB
类名称:RocksDB
方法名:multiGet
[英]Returns a map of keys for which values were found in DB.
[中]返回在DB中找到其值的键的映射。
代码示例来源:origin: alibaba/jstorm
Map<byte[], byte[]> results = db.multiGet(lookupKeys);
if (results == null || results.size() == 0) {
return;
代码示例来源:origin: org.rocksdb/rocksdbjni
final byte[][] values = multiGet(nativeHandle_, opt.nativeHandle_,
keysArray, keyOffsets, keyLengths);
代码示例来源:origin: com.alibaba.jstorm/jstorm-core
Map<byte[], byte[]> results = db.multiGet(lookupKeys);
if (results == null || results.size() == 0) {
return;
代码示例来源:origin: org.rocksdb/rocksdbjni
final byte[][] values = multiGet(nativeHandle_, keysArray, keyOffsets,
keyLengths);
代码示例来源:origin: com.palantir.atlasdb/atlasdb-rocksdb
@Override
public Map<TableReference, byte[]> getMetadataForTables() {
Set<String> tableNames = columnFamilies.getTableNames();
List<ColumnFamilyHandle> tables = Lists.newArrayListWithCapacity(tableNames.size());
List<byte[]> keys = Lists.newArrayListWithCapacity(tableNames.size());
try (ColumnFamily metadataTable = columnFamilies.get(METADATA_TABLE_NAME.getQualifiedName())) {
for (String tableName : tableNames) {
tables.add(metadataTable.getHandle());
keys.add(tableName.getBytes(Charsets.UTF_8));
}
Map<byte[], byte[]> rawResults = getDb().multiGet(tables, keys);
Map<TableReference, byte[]> results = Maps.newHashMapWithExpectedSize(rawResults.size());
for (Entry<byte[], byte[]> entry : rawResults.entrySet()) {
results.put(TableReference.createUnsafe(new String(entry.getKey(), Charsets.UTF_8)), entry.getValue());
}
return results;
} catch (RocksDBException e) {
throw Throwables.propagate(e);
}
}
代码示例来源:origin: org.rocksdb/rocksdbjni
final byte[][] values = multiGet(nativeHandle_, keysArray, keyOffsets,
keyLengths, cfHandles);
代码示例来源:origin: org.rocksdb/rocksdbjni
final byte[][] values = multiGet(nativeHandle_, opt.nativeHandle_,
keysArray, keyOffsets, keyLengths, cfHandles);
代码示例来源:origin: locationtech/geowave
public synchronized CloseableIterator<GeoWaveRow> dataIndexIterator(final byte[][] dataIds) {
final RocksDB readDb = getReadDb();
if (readDb == null) {
return new CloseableIterator.Empty<>();
}
try {
final List<byte[]> dataIdsList = Arrays.asList(dataIds);
final Map<byte[], byte[]> dataIdxResults = readDb.multiGet(dataIdsList);
return new CloseableIterator.Wrapper(
dataIdsList.stream().map(
dataId -> DataIndexUtils.deserializeDataIndexRow(
dataId,
adapterId,
dataIdxResults.get(dataId),
visibilityEnabled)).iterator());
} catch (final RocksDBException e) {
LOGGER.error("Unable to get values by data ID", e);
}
return new CloseableIterator.Empty<>();
}
}
内容来源于网络,如有侵权,请联系作者删除!