class KTableSuppressProcessor implements Processor<K, Change<V>> {

    @Override
    public void process(final K key, final Change<V> value) {
        observedStreamTime = Math.max(observedStreamTime, internalProcessorContext.timestamp());
        buffer(key, value);
        enforceConstraints();
    }

    public  KTableSuppressProcessor(final SuppressedInternal<K> suppress, final String storeName);

}