Class KeyRemovingMapper<T,K>
- java.lang.Object
-
- org.apache.flink.api.common.functions.AbstractRichFunction
-
- org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<K,T>,T>
-
- org.apache.flink.api.java.operators.translation.KeyRemovingMapper<T,K>
-
- Type Parameters:
T- type of valuesK- type of keys
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<K,T>,T>,org.apache.flink.api.common.functions.RichFunction
@Internal public final class KeyRemovingMapper<T,K> extends org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<K,T>,T>Mapper that removes keys.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description KeyRemovingMapper()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Tmap(org.apache.flink.api.java.tuple.Tuple2<K,T> value)-
Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
-
-