org.apache.kafka.streams.kstream

Interface KeyValueMapper<K,V,R>

Type Parameters:

K - original key type

V - original value type

R - mapped value type

public interface KeyValueMapper<K,V,R>

The KeyValueMapper interface for mapping a key-value pair to a new value (could be another key-value pair).

Method Summary

Modifier and Type	Method and Description
R	apply(K key, V value) Map a record with the given key and value to a new value.

Method Detail

apply

R apply(K key,
        V value)

Map a record with the given key and value to a new value.

Parameters:

key - the key of the record

value - the value of the record

Returns:

the new value