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 RichJoinFunction<IN1,IN2,OUT> extends AbstractRichFunction implements JoinFunction<IN1,IN2,OUT>
JoinFunction
. As a RichFunction
, it gives access to the
RuntimeContext
and provides setup and teardown
methods: RichFunction.open(OpenContext)
and RichFunction.close()
.Constructor and Description |
---|
RichJoinFunction() |
Modifier and Type | Method and Description |
---|---|
abstract OUT |
join(IN1 first,
IN2 second)
The join method, called once per joined pair of elements.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
public abstract OUT join(IN1 first, IN2 second) throws Exception
JoinFunction
join
in interface JoinFunction<IN1,IN2,OUT>
first
- The element from first input.second
- The element from second input.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.