本文整理了Java中org.rocksdb.Options.setCreateMissingColumnFamilies()
方法的一些代码示例,展示了Options.setCreateMissingColumnFamilies()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Options.setCreateMissingColumnFamilies()
方法的具体详情如下:
包路径:org.rocksdb.Options
类名称:Options
方法名:setCreateMissingColumnFamilies
暂无
代码示例来源:origin: alibaba/jstorm
public void initDb(List<Integer> list) throws Exception {
Options dbOptions = new Options().setCreateMissingColumnFamilies(true).setCreateIfMissing(true);
initDb(list, dbOptions);
}
代码示例来源:origin: alibaba/jstorm
public RocksDbCacheOperator(TopologyContext context, String cacheDir) {
this.stormConf = context.getStormConf();
this.maxFlushSize = ConfigExtension.getTransactionCacheBatchFlushSize(stormConf);
Options rocksDbOpt = new Options();
rocksDbOpt.setCreateMissingColumnFamilies(true).setCreateIfMissing(true);
long bufferSize =
ConfigExtension.getTransactionCacheBlockSize(stormConf) != null ? ConfigExtension.getTransactionCacheBlockSize(stormConf) : (1 * SizeUnit.GB);
rocksDbOpt.setWriteBufferSize(bufferSize);
int maxBufferNum = ConfigExtension.getTransactionMaxCacheBlockNum(stormConf) != null ? ConfigExtension.getTransactionMaxCacheBlockNum(stormConf) : 3;
rocksDbOpt.setMaxWriteBufferNumber(maxBufferNum);
// Config for log of RocksDb
rocksDbOpt.setMaxLogFileSize(1073741824); // 1G
rocksDbOpt.setKeepLogFileNum(1);
rocksDbOpt.setInfoLogLevel(InfoLogLevel.WARN_LEVEL);
try {
Map<Object, Object> conf = new HashMap<Object, Object>();
conf.put(ROCKSDB_ROOT_DIR, cacheDir);
conf.put(ROCKSDB_RESET, true);
initDir(conf);
initDb(null, rocksDbOpt);
} catch (Exception e) {
throw new RuntimeException(e);
}
kryo = new Kryo();
output = new Output(200, 2000000000);
input = new Input(1);
LOG.info("Finished rocksDb cache init: maxFlushSize={}, bufferSize={}, maxBufferNum={}", maxFlushSize, bufferSize, maxBufferNum);
}
代码示例来源:origin: brianfrankcooper/YCSB
.optimizeLevelStyleCompaction()
.setCreateIfMissing(true)
.setCreateMissingColumnFamilies(true)
.setIncreaseParallelism(rocksThreads)
.setMaxBackgroundCompactions(rocksThreads)
代码示例来源:origin: alibaba/jstorm
try {
Options options = new Options();
options.setCreateMissingColumnFamilies(true);
options.setCreateIfMissing(true);
options.setTargetFileSizeBase(fileSizeBase);
代码示例来源:origin: alibaba/jstorm
currentOptions = new Options();
currentOptions.setCreateIfMissing(true);
currentOptions.setCreateMissingColumnFamilies(true);
currentOptions.setMergeOperator(new StringAppendOperator());
代码示例来源:origin: org.rocksdb/rocksdbjni
@Override
public Options setCreateMissingColumnFamilies(final boolean flag) {
assert(isOwningHandle());
setCreateMissingColumnFamilies(nativeHandle_, flag);
return this;
}
代码示例来源:origin: com.alibaba.jstorm/jstorm-core
public void initDb(List<Integer> list) throws Exception {
Options dbOptions = new Options().setCreateMissingColumnFamilies(true).setCreateIfMissing(true);
initDb(list, dbOptions);
}
代码示例来源:origin: jwplayer/southpaw
rocksDBOptions = new Options(dbOptions, cfOptions)
.setCreateIfMissing(true)
.setCreateMissingColumnFamilies(true)
.optimizeLevelStyleCompaction(memtableSize)
.setCompactionStyle(CompactionStyle.LEVEL)
代码示例来源:origin: com.alibaba.jstorm/jstorm-core
rocksDbOpt.setCreateMissingColumnFamilies(true).setCreateIfMissing(true);
long bufferSize = ConfigExtension.getTransactionCacheBlockSize(stormConf) != null ?
ConfigExtension.getTransactionCacheBlockSize(stormConf) : (1 * SizeUnit.GB);
代码示例来源:origin: actiontech/dble
setAllowMmapWrites(true).
setCreateIfMissing(true).
setCreateMissingColumnFamilies(true);
if (cacheSize > 0) {
CompactionOptionsFIFO fifo = new CompactionOptionsFIFO();
内容来源于网络,如有侵权,请联系作者删除!