T
- type of valueK
- type of key@Internal public final class KeyExtractingMapper<T,K> extends RichMapFunction<T,Tuple2<K,T>>
Constructor and Description |
---|
KeyExtractingMapper(KeySelector<T,K> keySelector) |
Modifier and Type | Method and Description |
---|---|
Tuple2<K,T> |
map(T value)
The mapping method.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public KeyExtractingMapper(KeySelector<T,K> keySelector)
public Tuple2<K,T> map(T value) throws Exception
MapFunction
map
in interface MapFunction<T,Tuple2<K,T>>
map
in class RichMapFunction<T,Tuple2<K,T>>
value
- The input value.Exception
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.