本文整理了Java中org.rocksdb.Options.setTableFormatConfig()
方法的一些代码示例,展示了Options.setTableFormatConfig()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Options.setTableFormatConfig()
方法的具体详情如下:
包路径:org.rocksdb.Options
类名称:Options
方法名:setTableFormatConfig
暂无
代码示例来源:origin: apache/storm
options.setTableFormatConfig(tfc);
options.useCappedPrefixExtractor(RocksDbKey.KEY_SIZE);
代码示例来源:origin: ethereum/ethereumj
options.setTableFormatConfig(tableCfg = new BlockBasedTableConfig());
tableCfg.setBlockSize(16 * 1024);
tableCfg.setBlockCacheSize(32 * 1024 * 1024);
代码示例来源:origin: ltsopensource/light-task-scheduler
@Override
protected void init() throws FailStoreException {
try {
options = new Options();
options.setCreateIfMissing(true)
.setWriteBufferSize(8 * SizeUnit.KB)
.setMaxWriteBufferNumber(3)
.setMaxBackgroundCompactions(10)
.setCompressionType(CompressionType.SNAPPY_COMPRESSION)
.setCompactionStyle(CompactionStyle.UNIVERSAL);
Filter bloomFilter = new BloomFilter(10);
BlockBasedTableConfig tableConfig = new BlockBasedTableConfig();
tableConfig.setBlockCacheSize(64 * SizeUnit.KB)
.setFilter(bloomFilter)
.setCacheNumShardBits(6)
.setBlockSizeDeviation(5)
.setBlockRestartInterval(10)
.setCacheIndexAndFilterBlocks(true)
.setHashIndexAllowCollision(false)
.setBlockCacheCompressedSize(64 * SizeUnit.KB)
.setBlockCacheCompressedNumShardBits(10);
options.setTableFormatConfig(tableConfig);
} catch (Exception e) {
throw new FailStoreException(e);
}
}
代码示例来源:origin: ltsopensource/light-task-scheduler
@Override
protected void init() throws FailStoreException {
try {
options = new Options();
options.setCreateIfMissing(true)
.setWriteBufferSize(8 * SizeUnit.KB)
.setMaxWriteBufferNumber(3)
.setMaxBackgroundCompactions(10)
.setCompressionType(CompressionType.SNAPPY_COMPRESSION)
.setCompactionStyle(CompactionStyle.UNIVERSAL);
Filter bloomFilter = new BloomFilter(10);
BlockBasedTableConfig tableConfig = new BlockBasedTableConfig();
tableConfig.setBlockCacheSize(64 * SizeUnit.KB)
.setFilter(bloomFilter)
.setCacheNumShardBits(6)
.setBlockSizeDeviation(5)
.setBlockRestartInterval(10)
.setCacheIndexAndFilterBlocks(true)
.setHashIndexAllowCollision(false)
.setBlockCacheCompressedSize(64 * SizeUnit.KB)
.setBlockCacheCompressedNumShardBits(10);
options.setTableFormatConfig(tableConfig);
} catch (Exception e) {
throw new FailStoreException(e);
}
}
代码示例来源:origin: alibaba/jstorm
currentOptions.setTableFormatConfig(tableOptions);
代码示例来源:origin: homeaway/stream-registry
@Override
public void setConfig(final String storeName, final Options options, final Map<String, Object> configs) {
BlockBasedTableConfig tableConfig = new org.rocksdb.BlockBasedTableConfig();
tableConfig.setBlockCacheSize(2 * 1024 * 1024L);
tableConfig.setBlockSize(2 * 1024L);
tableConfig.setCacheIndexAndFilterBlocks(true);
options.setTableFormatConfig(tableConfig);
options.setMaxWriteBufferNumber(2);
options.optimizeFiltersForHits();
}
}
代码示例来源:origin: pravega/pravega
private Options createDatabaseOptions() {
BlockBasedTableConfig tableFormatConfig = new BlockBasedTableConfig()
.setBlockSize(cacheBlockSizeKB * 1024L)
.setBlockCacheSize(readCacheSizeMB * 1024L * 1024L)
.setCacheIndexAndFilterBlocks(true);
return new Options()
.setCreateIfMissing(true)
.setDbLogDir(Paths.get(this.dbDir, DB_LOG_DIR).toString())
.setWalDir(Paths.get(this.dbDir, DB_WRITE_AHEAD_LOG_DIR).toString())
.setWalTtlSeconds(0)
.setWalSizeLimitMB(MAX_WRITE_AHEAD_LOG_SIZE_MB)
.setWriteBufferSize(writeBufferSizeMB * 1024L * 1024L)
.setMaxWriteBufferNumber(MAX_WRITE_BUFFER_NUMBER)
.setMinWriteBufferNumberToMerge(MIN_WRITE_BUFFER_NUMBER_TO_MERGE)
.setTableFormatConfig(tableFormatConfig)
.setOptimizeFiltersForHits(true)
.setUseDirectReads(true);
}
代码示例来源:origin: org.apache.kafka/kafka-streams
options.setTableFormatConfig(tableConfig);
options.setWriteBufferSize(WRITE_BUFFER_SIZE);
options.setCompressionType(COMPRESSION_TYPE);
代码示例来源:origin: opendedup/sdfs
options.setTableFormatConfig(blockConfig);
File f = new File(fileName + File.separator);
f.mkdirs();
代码示例来源:origin: apache/samza
BlockBasedTableConfig tableOptions = new BlockBasedTableConfig();
tableOptions.setBlockCacheSize(blockCacheSize).setBlockSize(blockSize);
options.setTableFormatConfig(tableOptions);
代码示例来源:origin: org.apache.samza/samza-kv-rocksdb
BlockBasedTableConfig tableOptions = new BlockBasedTableConfig();
tableOptions.setBlockCacheSize(blockCacheSize).setBlockSize(blockSize);
options.setTableFormatConfig(tableOptions);
代码示例来源:origin: org.apache.samza/samza-kv-rocksdb_2.11
BlockBasedTableConfig tableOptions = new BlockBasedTableConfig();
tableOptions.setBlockCacheSize(blockCacheSize).setBlockSize(blockSize);
options.setTableFormatConfig(tableOptions);
代码示例来源:origin: com.github.ltsopensource/lts-core
@Override
protected void init() throws FailStoreException {
try {
options = new Options();
options.setCreateIfMissing(true)
.setWriteBufferSize(8 * SizeUnit.KB)
.setMaxWriteBufferNumber(3)
.setMaxBackgroundCompactions(10)
.setCompressionType(CompressionType.SNAPPY_COMPRESSION)
.setCompactionStyle(CompactionStyle.UNIVERSAL);
Filter bloomFilter = new BloomFilter(10);
BlockBasedTableConfig tableConfig = new BlockBasedTableConfig();
tableConfig.setBlockCacheSize(64 * SizeUnit.KB)
.setFilter(bloomFilter)
.setCacheNumShardBits(6)
.setBlockSizeDeviation(5)
.setBlockRestartInterval(10)
.setCacheIndexAndFilterBlocks(true)
.setHashIndexAllowCollision(false)
.setBlockCacheCompressedSize(64 * SizeUnit.KB)
.setBlockCacheCompressedNumShardBits(10);
options.setTableFormatConfig(tableConfig);
} catch (Exception e) {
throw new FailStoreException(e);
}
}
代码示例来源:origin: org.apache.bookkeeper/bookkeeper-server
options.setLevelCompactionDynamicLevelBytes(true);
options.setTableFormatConfig(tableOptions);
内容来源于网络,如有侵权,请联系作者删除!