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

Options.setIncreaseParallelism介绍

暂无

代码示例

代码示例来源：origin: brianfrankcooper/YCSB

.setCreateIfMissing(true)
.setCreateMissingColumnFamilies(true)
.setIncreaseParallelism(rocksThreads)
.setMaxBackgroundCompactions(rocksThreads)
.setInfoLogLevel(InfoLogLevel.INFO_LEVEL);

代码示例来源：origin: ethereum/ethereumj

options.setLevelCompactionDynamicLevelBytes(true);
options.setMaxOpenFiles(settings.getMaxOpenFiles());
options.setIncreaseParallelism(settings.getMaxThreads());

代码示例来源：origin: confluentinc/kafka-streams-examples

@Override
 public void setConfig(final String storeName, final Options options,
   final Map<String, Object> configs) {
  // Workaround: We must ensure that the parallelism is set to >= 2.  There seems to be a known
  // issue with RocksDB where explicitly setting the parallelism to 1 causes issues (even though
  // 1 seems to be RocksDB's default for this configuration).
  int compactionParallelism = Math.max(Runtime.getRuntime().availableProcessors(), 2);
  // Set number of compaction threads (but not flush threads).
  options.setIncreaseParallelism(compactionParallelism);
 }
}

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

@Override
public Options setIncreaseParallelism(final int totalThreads) {
 assert(isOwningHandle());
 setIncreaseParallelism(nativeHandle_, totalThreads);
 return this;
}

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

public synchronized RocksDBDataIndexTable getDataIndexTable(
  final String tableName,
  final short adapterId) {
 if (indexWriteOptions == null) {
  RocksDB.loadLibrary();
  final int cores = Runtime.getRuntime().availableProcessors();
  indexWriteOptions =
    new Options().setCreateIfMissing(true).prepareForBulkLoad().setIncreaseParallelism(cores);
  indexReadOptions = new Options().setIncreaseParallelism(cores);
 }
 final String directory = subDirectory + "/" + tableName;
 return dataIndexTableCache.get(
   (DataIndexCacheKey) keyCache.get(directory, d -> new DataIndexCacheKey(d, adapterId)));
}

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

public synchronized RocksDBIndexTable getIndexTable(
  final String tableName,
  final short adapterId,
  final byte[] partition,
  final boolean requiresTimestamp) {
 if (indexWriteOptions == null) {
  RocksDB.loadLibrary();
  final int cores = Runtime.getRuntime().availableProcessors();
  indexWriteOptions =
    new Options().setCreateIfMissing(true).prepareForBulkLoad().setIncreaseParallelism(cores);
  indexReadOptions = new Options().setIncreaseParallelism(cores);
 }
 final String directory = subDirectory + "/" + tableName;
 return indexTableCache.get(
   (IndexCacheKey) keyCache.get(
     directory,
     d -> new IndexCacheKey(d, adapterId, partition, requiresTimestamp)));
}

代码示例来源：origin: jwplayer/southpaw

.setCompactionStyle(CompactionStyle.LEVEL)
.setNumLevels(4)
.setIncreaseParallelism(parallelism)
.setCompactionReadaheadSize(compactionReadAheadSize)
.setMaxBackgroundCompactions(maxBackgroundCompactions)

代码示例来源：origin: org.apache.kafka/kafka-streams

options.setIncreaseParallelism(Math.max(Runtime.getRuntime().availableProcessors(), 2));

代码示例来源：origin: opendedup/sdfs

options.setEnv(env);
options.setAccessHintOnCompactionStart(AccessHint.WILLNEED);
options.setIncreaseParallelism(32);
options.setAdviseRandomOnOpen(true);

代码示例来源：origin: org.apache.bookkeeper/bookkeeper-server

options.setMaxBackgroundCompactions(16);
options.setMaxBackgroundFlushes(16);
options.setIncreaseParallelism(32);
options.setMaxTotalWalSize(512 * 1024 * 1024);
options.setMaxOpenFiles(-1);