class KTableFilter implements KTableProcessorSupplier<K, V, V> {

    @Override
    public Processor<K, Change<V>> get() {
        return new KTableFilterProcessor();
    }

    public  KTableFilter(KTableImpl<K, ?, V> parent, Predicate<K, V> predicate, boolean filterNot);

}