Class KTableRepartitionMap<K,​V,​K1,​V1>

  • All Implemented Interfaces:
    KTableProcessorSupplier<K,​V,​KeyValue<K1,​V1>>, ProcessorSupplier<K,​Change<V>>

    public class KTableRepartitionMap<K,​V,​K1,​V1>
    extends java.lang.Object
    implements KTableProcessorSupplier<K,​V,​KeyValue<K1,​V1>>
    KTable repartition map functions are not exposed to public APIs, but only used for keyed aggregations.

    Given the input, it can output at most two records (one mapped from old value and one mapped from new value).