Package org.apache.kafka.streams.kstream
Interface ValueMapperWithKey<K,V,VR>
-
- Type Parameters:
K
- key typeV
- value typeVR
- mapped value type
public interface ValueMapperWithKey<K,V,VR>
TheValueMapperWithKey
interface for mapping a value to a new value of arbitrary type. This is a stateless record-by-record operation, i.e,apply(Object, Object)
is invoked individually for each record of a stream (cf.ValueTransformer
for stateful value transformation). IfValueMapperWithKey
is applied to akey-value pair
record the record's key is preserved. Note that the key is read-only and should not be modified, as this can lead to corrupt partitioning. If a record's key and value should be modifiedKeyValueMapper
can be used.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description VR
apply(K readOnlyKey, V value)
Map the given [key and ]value to a new value.
-