本文整理了Java中org.rocksdb.Options.setInfoLogLevel()
方法的一些代码示例,展示了Options.setInfoLogLevel()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Options.setInfoLogLevel()
方法的具体详情如下:
包路径:org.rocksdb.Options
类名称:Options
方法名:setInfoLogLevel
暂无
代码示例来源:origin: brianfrankcooper/YCSB
.setIncreaseParallelism(rocksThreads)
.setMaxBackgroundCompactions(rocksThreads)
.setInfoLogLevel(InfoLogLevel.INFO_LEVEL);
dbOptions = options;
return RocksDB.open(options, rocksDbDir.toAbsolutePath().toString());
代码示例来源: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: nlpie/biomedicus
RocksDBNormalizerModel(Path dbPath) {
RocksDB.loadLibrary();
try (Options options = new Options().setInfoLogLevel(InfoLogLevel.ERROR_LEVEL)) {
db = RocksDB.openReadOnly(options, dbPath.toString());
} catch (RocksDBException e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: nlpie/biomedicus
public RocksDbIdentifiers(Path identifiersPath) {
RocksDB.loadLibrary();
try (Options options = new Options().setInfoLogLevel(InfoLogLevel.ERROR_LEVEL)) {
indices = RocksDB.openReadOnly(options, identifiersPath.toString());
} catch (RocksDBException e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: org.rocksdb/rocksdbjni
@Override
public Options setInfoLogLevel(final InfoLogLevel infoLogLevel) {
assert(isOwningHandle());
setInfoLogLevel(nativeHandle_, infoLogLevel.getValue());
return this;
}
代码示例来源:origin: nlpie/biomedicus
RocksDB.loadLibrary();
try (Options options = new Options().setInfoLogLevel(InfoLogLevel.ERROR_LEVEL)) {
LOGGER.info("Opening concepts dictionary: {}. inMemory = {}.", dbPath, inMemory);
代码示例来源:origin: org.apache.kafka/kafka-streams
options.setCreateIfMissing(true);
options.setErrorIfExists(false);
options.setInfoLogLevel(InfoLogLevel.ERROR_LEVEL);
代码示例来源:origin: org.apache.bookkeeper/bookkeeper-server
switch (logLevel) {
case "debug":
options.setInfoLogLevel(InfoLogLevel.DEBUG_LEVEL);
break;
case "info":
options.setInfoLogLevel(InfoLogLevel.INFO_LEVEL);
break;
case "warn":
options.setInfoLogLevel(InfoLogLevel.WARN_LEVEL);
break;
case "error":
options.setInfoLogLevel(InfoLogLevel.ERROR_LEVEL);
break;
default:
内容来源于网络,如有侵权,请联系作者删除!