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

Class TwoKeyExtractingMapper<T,K1,K2>

java.lang.Object

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

org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>>

org.apache.flink.api.java.operators.translation.TwoKeyExtractingMapper<T,K1,K2>

Type Parameters:

T - type of the values

K1 - type of the first key

K2 - type of the second key

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<T,org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>>, org.apache.flink.api.common.functions.RichFunction

@Internal
public final class TwoKeyExtractingMapper<T,K1,K2>
extends org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>>

Mapper that extracts two keys of a value.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
TwoKeyExtractingMapper(org.apache.flink.api.java.functions.KeySelector<T,K1> keySelector1, org.apache.flink.api.java.functions.KeySelector<T,K2> keySelector2)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>	map(T value)

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

Methods inherited from interface org.apache.flink.api.common.functions.RichFunction

open

Constructor Detail

TwoKeyExtractingMapper

public TwoKeyExtractingMapper(org.apache.flink.api.java.functions.KeySelector<T,K1> keySelector1,
                              org.apache.flink.api.java.functions.KeySelector<T,K2> keySelector2)

Method Detail

map

public org.apache.flink.api.java.tuple.Tuple3<K1,K2,T> map(T value)
                                                                throws Exception

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<T,K1>

Specified by:

map in class org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>>

Throws:

Exception