@Test public void shouldSetColumnFamilyOptionsConfig() { final BrokerCfg cfg = TestConfigReader.readConfig("rocksdb-cfg", environment); final var rocksdb = cfg.getData().getRocksdb(); final var columnFamilyOptions = rocksdb.getColumnFamilyOptions(); assertThat(columnFamilyOptions).containsEntry("compaction_pri", "kOldestSmallestSeqFirst"); assertThat(columnFamilyOptions).containsEntry("write_buffer_size", "67108864"); }
public Properties getColumnFamilyOptions() { return columnFamilyOptions; }
RocksdbCfg implements ConfigurationEntry { public Properties getColumnFamilyOptions() { return columnFamilyOptions; } }
RocksdbCfg implements ConfigurationEntry { public Properties getColumnFamilyOptions() { return columnFamilyOptions; }  }
RocksdbCfg implements ConfigurationEntry { public Properties getColumnFamilyOptions() { return columnFamilyOptions; }  @Override void init(final BrokerCfg globalConfig, final String brokerBase); Properties getColumnFamilyOptions(); void setColumnFamilyOptions(final Properties columnFamilyOptions); }
RocksdbCfg implements ConfigurationEntry { public Properties getColumnFamilyOptions() { return columnFamilyOptions; }  @Override void init(final BrokerCfg globalConfig, final String brokerBase); Properties getColumnFamilyOptions(); void setColumnFamilyOptions(final Properties columnFamilyOptions);  }