Class SeparatedStoreBufferService

  • All Implemented Interfaces:, java.lang.AutoCloseable

    public class SeparatedStoreBufferService
    extends AbstractStoreBufferService
    This store buffer services maintains two separate drainer queues for store ingestions. For the sorted messages, Venice SN could use SSTFileWriter to ingest into RocksDB, and the performance is constant and stable. But for the unsorted messages, RocksDB behavior is not constant because of RocksDB compaction and sometimes write compute. Since there are very different characteristics, it will be helpful to decouple these two types of ingestions to avoid one blocking the other.