IN1- Type of the first input
IN2- Type of the second input
OUT- Type of the output
@PublicEvolving public abstract class ProcessJoinFunction<IN1,IN2,OUT> extends AbstractRichFunction
This function will get called for every joined pair of elements the joined two streams.
The timestamp of the joined pair as well as the timestamp of the left element and the right
element can be accessed through the
|Modifier and Type||Class and Description|
The context that is available during an invocation of
|Constructor and Description|
|Modifier and Type||Method and Description|
This method is called for each joined pair of elements.
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract void processElement(IN1 left, IN2 right, ProcessJoinFunction.Context ctx, Collector<OUT> out) throws Exception
Collectorand has access to the timestamps of the joined elements and the result through the
left- The left element of the joined pair.
right- The right element of the joined pair.
ctx- A context that allows querying the timestamps of the left, right and joined pair. In addition, this context allows to emit elements on a side output.
out- The collector to emit resulting elements to.
Exception- This function may throw exceptions which cause the streaming program to fail and go in recovery mode.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.