org.rocksdb.BlockBasedTableConfig.setBlockSize()方法的使用及代码示例

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

BlockBasedTableConfig.setBlockSize介绍

[英]Approximate size of user data packed per block. Note that the block size specified here corresponds to uncompressed data. The actual size of the unit read from disk may be smaller if compression is enabled. This parameter can be changed dynamically. Default: 4K
[中]每个块打包的用户数据的近似大小。请注意，此处指定的块大小对应于未压缩的数据。如果启用压缩，则从磁盘读取的单元的实际大小可能更小。此参数可以动态更改。默认值：4K

代码示例

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

tableCfg.setBlockSize(16 * 1024);
tableCfg.setBlockCacheSize(32 * 1024 * 1024);
tableCfg.setCacheIndexAndFilterBlocks(true);

代码示例来源：origin: apache/flink

@Override
public ColumnFamilyOptions createColumnOptions() {
final long blockCacheSize = 256 * 1024 * 1024;
final long blockSize = 128 * 1024;
final long targetFileSize = 256 * 1024 * 1024;
final long writeBufferSize = 64 * 1024 * 1024;
return new ColumnFamilyOptions()
.setCompactionStyle(CompactionStyle.LEVEL)
.setLevelCompactionDynamicLevelBytes(true)
.setTargetFileSizeBase(targetFileSize)
.setMaxBytesForLevelBase(4 * targetFileSize)
.setWriteBufferSize(writeBufferSize)
.setMinWriteBufferNumberToMerge(3)
.setMaxWriteBufferNumber(4)
.setTableFormatConfig(
new BlockBasedTableConfig()
.setBlockCacheSize(blockCacheSize)
.setBlockSize(blockSize)
.setFilter(new BloomFilter())
);
}
},

代码示例来源：origin: alibaba/jstorm

tableOptions.setBlockSize(32 * SizeUnit.KB);

代码示例来源：origin: alibaba/jstorm

tableOptions.setBlockSize(32 * SizeUnit.KB);

代码示例来源：origin: homeaway/stream-registry

@Override
public void setConfig(final String storeName, final Options options, final Map 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: opendedup/sdfs

blockConfig.setBlockSize(4 * 1024);
blockConfig.setFormatVersion(2);
blockConfig.setNoBlockCache(true);

代码示例来源：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

tableConfig.setBlockSize(BLOCK_SIZE);

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

tableConfig.setBlockSize(BLOCK_SIZE);
tableConfig.setChecksumType(DEFAULT_CHECKSUM_TYPE);

代码示例来源：origin: org.apache.flink/flink-statebackend-rocksdb_2.10

@Override
public ColumnFamilyOptions createColumnOptions() {
final long blockCacheSize = 256 * 1024 * 1024;
final long blockSize = 128 * 1024;
final long targetFileSize = 256 * 1024 * 1024;
final long writeBufferSize = 64 * 1024 * 1024;
return new ColumnFamilyOptions()
.setMergeOperator(new StringAppendOperator())
.setCompactionStyle(CompactionStyle.LEVEL)
.setLevelCompactionDynamicLevelBytes(true)
.setTargetFileSizeBase(targetFileSize)
.setMaxBytesForLevelBase(4 * targetFileSize)
.setWriteBufferSize(writeBufferSize)
.setMinWriteBufferNumberToMerge(3)
.setMaxWriteBufferNumber(4)
.setTableFormatConfig(
new BlockBasedTableConfig()
.setBlockCacheSize(blockCacheSize)
.setBlockSize(blockSize)
);
}
},

代码示例来源：origin: org.apache.flink/flink-statebackend-rocksdb

@Override
public ColumnFamilyOptions createColumnOptions() {
final long blockCacheSize = 256 * 1024 * 1024;
final long blockSize = 128 * 1024;
final long targetFileSize = 256 * 1024 * 1024;
final long writeBufferSize = 64 * 1024 * 1024;
return new ColumnFamilyOptions()
.setCompactionStyle(CompactionStyle.LEVEL)
.setLevelCompactionDynamicLevelBytes(true)
.setTargetFileSizeBase(targetFileSize)
.setMaxBytesForLevelBase(4 * targetFileSize)
.setWriteBufferSize(writeBufferSize)
.setMinWriteBufferNumberToMerge(3)
.setMaxWriteBufferNumber(4)
.setTableFormatConfig(
new BlockBasedTableConfig()
.setBlockCacheSize(blockCacheSize)
.setBlockSize(blockSize)
.setFilter(new BloomFilter())
);
}
},

代码示例来源：origin: org.apache.flink/flink-statebackend-rocksdb_2.11

@Override
public ColumnFamilyOptions createColumnOptions() {
final long blockCacheSize = 256 * 1024 * 1024;
final long blockSize = 128 * 1024;
final long targetFileSize = 256 * 1024 * 1024;
final long writeBufferSize = 64 * 1024 * 1024;
return new ColumnFamilyOptions()
.setCompactionStyle(CompactionStyle.LEVEL)
.setLevelCompactionDynamicLevelBytes(true)
.setTargetFileSizeBase(targetFileSize)
.setMaxBytesForLevelBase(4 * targetFileSize)
.setWriteBufferSize(writeBufferSize)
.setMinWriteBufferNumberToMerge(3)
.setMaxWriteBufferNumber(4)
.setTableFormatConfig(
new BlockBasedTableConfig()
.setBlockCacheSize(blockCacheSize)
.setBlockSize(blockSize)
.setFilter(new BloomFilter())
);
}
},

代码示例来源：origin: apache/samza

int blockSize = storeConfig.getInt(ROCKSDB_BLOCK_SIZE_BYTES, 4096);
BlockBasedTableConfig tableOptiOns= new BlockBasedTableConfig();
tableOptions.setBlockCacheSize(blockCacheSize).setBlockSize(blockSize);
options.setTableFormatConfig(tableOptions);

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

blockConfig.setBlockSize(4 * 1024);
blockConfig.setFormatVersion(2);
blockConfig.setNoBlockCache(true);

代码示例来源：origin: org.apache.samza/samza-kv-rocksdb

int blockSize = storeConfig.getInt(ROCKSDB_BLOCK_SIZE_BYTES, 4096);
BlockBasedTableConfig tableOptiOns= new BlockBasedTableConfig();
tableOptions.setBlockCacheSize(blockCacheSize).setBlockSize(blockSize);
options.setTableFormatConfig(tableOptions);

代码示例来源：origin: org.apache.samza/samza-kv-rocksdb_2.11

int blockSize = storeConfig.getInt(ROCKSDB_BLOCK_SIZE_BYTES, 4096);
BlockBasedTableConfig tableOptiOns= new BlockBasedTableConfig();
tableOptions.setBlockCacheSize(blockCacheSize).setBlockSize(blockSize);
options.setTableFormatConfig(tableOptions);

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

tableOptions.setBlockSize(blockSize);
tableOptions.setBlockCacheSize(blockCacheSize);
tableOptions.setFormatVersion(2);