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>TheValueMapperWithKeyinterface 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.ValueTransformerfor stateful value transformation). IfValueMapperWithKeyis applied to akey-value pairrecord 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 modifiedKeyValueMappercan be used.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description VRapply(K readOnlyKey, V value)Map the given [key and ]value to a new value.
-