org.rocksdb.Options.setTableFormatConfig()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(138)

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

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);

相关文章

Options类方法