org.apache.flink.api.java.operators

Class JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT>

java.lang.Object

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

org.apache.flink.api.java.operators.translation.WrappingFunction<JoinFunction<IN1,IN2,OUT>>

org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT>

Type Parameters:

IN1 - type of elements of first collection

IN2 - type of elements of second collection

OUT - type of elements of resulting elements

All Implemented Interfaces:

Serializable, FlatJoinFunction<IN1,IN2,OUT>, Function, RichFunction

Enclosing class:

JoinOperator.DefaultJoin<I1,I2>

@Internal
public static class JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT>
extends WrappingFunction<JoinFunction<IN1,IN2,OUT>>
implements FlatJoinFunction<IN1,IN2,OUT>

Wrapper around JoinFunction.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.api.java.operators.translation.WrappingFunction

wrappedFunction

Constructor Summary

Constructors

Constructor and Description
WrappingFlatJoinFunction(JoinFunction<IN1,IN2,OUT> wrappedFunction)

Method Summary

Modifier and Type	Method and Description
void	join(IN1 left, IN2 right, Collector<OUT> out) The join method, called once per joined pair of elements.

Methods inherited from class org.apache.flink.api.java.operators.translation.WrappingFunction

close, getWrappedFunction, open, setRuntimeContext

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

getIterationRuntimeContext, getRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

WrappingFlatJoinFunction

public WrappingFlatJoinFunction(JoinFunction<IN1,IN2,OUT> wrappedFunction)

Method Detail

join

public void join(IN1 left,
                 IN2 right,
                 Collector<OUT> out)
          throws Exception

Description copied from interface: FlatJoinFunction

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

Specified by:

join in interface FlatJoinFunction<IN1,IN2,OUT>

Parameters:

left - The element from first input.

right - 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.