org.apache.flink.api.java.operators

Class JoinOperator.DefaultFlatJoinFunction<T1,T2>

java.lang.Object

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

org.apache.flink.api.common.functions.RichFlatJoinFunction<T1,T2,Tuple2<T1,T2>>

org.apache.flink.api.java.operators.JoinOperator.DefaultFlatJoinFunction<T1,T2>

All Implemented Interfaces:

Serializable, FlatJoinFunction<T1,T2,Tuple2<T1,T2>>, Function, RichFunction

Enclosing class:

JoinOperator<I1,I2,OUT>

@Internal
public static final class JoinOperator.DefaultFlatJoinFunction<T1,T2>
extends RichFlatJoinFunction<T1,T2,Tuple2<T1,T2>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultFlatJoinFunction()

Method Summary

Modifier and Type	Method and Description
void	join(T1 first, T2 second, Collector<Tuple2<T1,T2>> out) The join method, called once per joined pair of elements.

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

DefaultFlatJoinFunction

public DefaultFlatJoinFunction()

Method Detail

join

public void join(T1 first,
                 T2 second,
                 Collector<Tuple2<T1,T2>> out)
          throws Exception

Description copied from interface: FlatJoinFunction

The join method, called once per joined pair of elements.

Specified by:

join in interface FlatJoinFunction<T1,T2,Tuple2<T1,T2>>

Specified by:

join in class RichFlatJoinFunction<T1,T2,Tuple2<T1,T2>>

Parameters:

first - The element from first input.

second - The element from second input.

out - The collector used to return zero, one, or more elements.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.