org.apache.flink.api.java.operators.translation

Class KeyRemovingMapper<T,K>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichMapFunction<Tuple2<K,T>,T>

org.apache.flink.api.java.operators.translation.KeyRemovingMapper<T,K>

All Implemented Interfaces:

Serializable, Function, MapFunction<Tuple2<K,T>,T>, RichFunction

@Internal
public final class KeyRemovingMapper<T,K>
extends RichMapFunction<Tuple2<K,T>,T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyRemovingMapper()

Method Summary

Modifier and Type	Method and Description
T	map(Tuple2<K,T> value) The mapping method.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KeyRemovingMapper

public KeyRemovingMapper()

Method Detail

map

public T map(Tuple2<K,T> value)

Description copied from interface: MapFunction

The mapping method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

map in interface MapFunction<Tuple2<K,T>,T>

Specified by:

map in class RichMapFunction<Tuple2<K,T>,T>

Parameters:

value - The input value.

Returns:

The transformed value