Package org.apache.kafka.streams.kstream
Interface ValueMapper<V,VR>
-
- Type Parameters:
V
- value typeVR
- mapped value type
public interface ValueMapper<V,VR>
TheValueMapper
interface for mapping a value to a new value of arbitrary type. This is a stateless record-by-record operation, i.e,apply(Object)
is invoked individually for each record of a stream (cf.ValueTransformer
for stateful value transformation). IfValueMapper
is applied to akey-value pair
record the record's key is preserved. 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(V value)
Map the given value to a new value.
-