K - key typeV - value typeVR - mapped value typepublic interface KeyValueMapper<K,V,VR>KeyValueMapper interface for mapping a key-value pair to a new value of arbitrary type. For example, it can be used to KeyValue pair to an output KeyValue pair with different key and/or value type (for this case output type VR == KeyValue<NewKeyType,NewValueType>)VR)apply(Object, Object) is invoked individually for each record of a stream (cf. Transformer for stateful record transformation). KeyValueMapper is a generalization of ValueMapper.ValueMapper, Transformer, KStream.map(KeyValueMapper), KStream.flatMap(KeyValueMapper), KStream.selectKey(KeyValueMapper), KStream.groupBy(KeyValueMapper), KStream.groupBy(KeyValueMapper, Grouped), KTable.groupBy(KeyValueMapper), KTable.groupBy(KeyValueMapper, Grouped), KTable.toStream(KeyValueMapper)| Modifier and Type | Method and Description |
|---|---|
VR | apply(K key, V value)Map a record with the given key and value to a new value. |