|
|
|
@ -57,38 +57,35 @@ public class RocksDBSample { |
|
|
|
|
assert(options.compressionType() == CompressionType.SNAPPY_COMPRESSION); |
|
|
|
|
assert(options.compactionStyle() == CompactionStyle.UNIVERSAL); |
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
assert(options.memTableFactoryName().equals("SkipListFactory")); |
|
|
|
|
options.setMemTableConfig( |
|
|
|
|
new HashSkipListMemTableConfig() |
|
|
|
|
.setHeight(4) |
|
|
|
|
.setBranchingFactor(4) |
|
|
|
|
.setBucketCount(2000000)); |
|
|
|
|
assert(options.memTableFactoryName().equals("HashSkipListRepFactory")); |
|
|
|
|
|
|
|
|
|
options.setMemTableConfig( |
|
|
|
|
new HashLinkedListMemTableConfig() |
|
|
|
|
.setBucketCount(100000)); |
|
|
|
|
assert(options.memTableFactoryName().equals("HashLinkedListRepFactory")); |
|
|
|
|
|
|
|
|
|
options.setMemTableConfig( |
|
|
|
|
new VectorMemTableConfig().setReservedSize(10000)); |
|
|
|
|
assert(options.memTableFactoryName().equals("VectorRepFactory")); |
|
|
|
|
|
|
|
|
|
options.setMemTableConfig(new SkipListMemTableConfig()); |
|
|
|
|
assert(options.memTableFactoryName().equals("SkipListFactory")); |
|
|
|
|
|
|
|
|
|
options.setTableFormatConfig(new PlainTableConfig()); |
|
|
|
|
// Plain-Table requires mmap read
|
|
|
|
|
options.setAllowMmapReads(true); |
|
|
|
|
assert(options.tableFactoryName().equals("PlainTable")); |
|
|
|
|
|
|
|
|
|
options.setRateLimiterConfig(new GenericRateLimiterConfig(10000000, |
|
|
|
|
10000, 10)); |
|
|
|
|
options.setRateLimiterConfig(new GenericRateLimiterConfig(10000000)); |
|
|
|
|
} catch (RocksDBException e) { |
|
|
|
|
assert(false); |
|
|
|
|
} |
|
|
|
|
assert(options.memTableFactoryName().equals("SkipListFactory")); |
|
|
|
|
options.setMemTableConfig( |
|
|
|
|
new HashSkipListMemTableConfig() |
|
|
|
|
.setHeight(4) |
|
|
|
|
.setBranchingFactor(4) |
|
|
|
|
.setBucketCount(2000000)); |
|
|
|
|
assert(options.memTableFactoryName().equals("HashSkipListRepFactory")); |
|
|
|
|
|
|
|
|
|
options.setMemTableConfig( |
|
|
|
|
new HashLinkedListMemTableConfig() |
|
|
|
|
.setBucketCount(100000)); |
|
|
|
|
assert(options.memTableFactoryName().equals("HashLinkedListRepFactory")); |
|
|
|
|
|
|
|
|
|
options.setMemTableConfig( |
|
|
|
|
new VectorMemTableConfig().setReservedSize(10000)); |
|
|
|
|
assert(options.memTableFactoryName().equals("VectorRepFactory")); |
|
|
|
|
|
|
|
|
|
options.setMemTableConfig(new SkipListMemTableConfig()); |
|
|
|
|
assert(options.memTableFactoryName().equals("SkipListFactory")); |
|
|
|
|
|
|
|
|
|
options.setTableFormatConfig(new PlainTableConfig()); |
|
|
|
|
// Plain-Table requires mmap read
|
|
|
|
|
options.setAllowMmapReads(true); |
|
|
|
|
assert(options.tableFactoryName().equals("PlainTable")); |
|
|
|
|
|
|
|
|
|
options.setRateLimiterConfig(new GenericRateLimiterConfig(10000000, |
|
|
|
|
10000, 10)); |
|
|
|
|
options.setRateLimiterConfig(new GenericRateLimiterConfig(10000000)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Filter bloomFilter = new BloomFilter(10); |
|
|
|
|
BlockBasedTableConfig table_options = new BlockBasedTableConfig(); |
|
|
|
|