@Internal public final class TwoKeyExtractingMapper<T,K1,K2> extends RichMapFunction<T,Tuple3<K1,K2,T>>
Constructor and Description |
---|
TwoKeyExtractingMapper(KeySelector<T,K1> keySelector1,
KeySelector<T,K2> keySelector2) |
Modifier and Type | Method and Description |
---|---|
Tuple3<K1,K2,T> |
map(T value)
The mapping method.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public TwoKeyExtractingMapper(KeySelector<T,K1> keySelector1, KeySelector<T,K2> keySelector2)
public Tuple3<K1,K2,T> map(T value) throws Exception
MapFunction
map
in interface MapFunction<T,Tuple3<K1,K2,T>>
map
in class RichMapFunction<T,Tuple3<K1,K2,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–2017 The Apache Software Foundation. All rights reserved.