IN1
- The type of the elements in the first input.IN2
- The type of the elements in the second input.OUT
- The type of the result elements.@Public public abstract class RichFlatJoinFunction<IN1,IN2,OUT> extends AbstractRichFunction implements FlatJoinFunction<IN1,IN2,OUT>
FlatJoinFunction
. As a RichFunction
, it gives access to the
RuntimeContext
and provides setup and teardown
methods: RichFunction.open(org.apache.flink.configuration.Configuration)
and RichFunction.close()
.Constructor and Description |
---|
RichFlatJoinFunction() |
Modifier and Type | Method and Description |
---|---|
abstract void |
join(IN1 first,
IN2 second,
Collector<OUT> out)
The join method, called once per joined pair of elements.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract void join(IN1 first, IN2 second, Collector<OUT> out) throws Exception
FlatJoinFunction
join
in interface FlatJoinFunction<IN1,IN2,OUT>
first
- The element from first input.second
- The element from second input.out
- The collector used to return zero, one, or more elements.Exception
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.