...
Code Block | ||
---|---|---|
| ||
public class SuppressionBufferBuilder<K, V> extends AbstractStoreBuilder<K, V, SuppressionBuffer<K, V>> { private final SuppressionBytesStoreSupplier storeSupplier; public SuppressionBufferBuilder(final SuppressionBytesStoreSupplier storeSupplier, final Serde<K> keySerde, final Serde<V> valueSerde, final Time time) { super(Objects.requireNonNull(storeSupplier, "supplier cannot be null").name(), keySerde, valueSerde, time); this.storeSupplier = storeSupplier; } @Override public SuppressionBuffer<K, V> build() { return new MeteredSuppressionBuffer<>( storeSupplier.get(enableLogging), storeSupplier.metricsScope(), time, keySerde, valueSerde); } } |
3. Add a new QueryableStoreType, SuppressionBufferType
This change makes SuppressionBuffer
queriable.
...