THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** This class contains all logical related to process records from two non-broadcast input. */
public interface TwoInputNonBroadcastStreamProcessFunction<IN1, IN2, OUT> extends ProcessFunction {
/**
* Process record from first input and emit data through {@link Collector}.
*
* @param record to process.
* @param output to emit processed records.
* @param ctx, runtime context in which this function is executed.
*/
void processRecordFromFirstInput(IN1 record, Collector<OUT> output, RuntimeContext ctx)
throws Exception;
/**
* Process record from second input and emit data through {@link Collector}.
*
* @param record to process.
* @param output to emit processed records.
* @param ctx, runtime context in which this function is executed.
*/
void processRecordFromSecondInput(IN2 record, Collector<OUT> output, RuntimeContext ctx)
throws Exception;
/**
* This is a life-cycle method indicates that this function will no longer receive any data from
* the first input.
*
* @param ctx, the context in which this function is executed.
*/
default void endFirstInput(NonPartitionedContext ctx) {}
/**
* This is a life-cycle method indicates that this function will no longer receive any data from
* the second input.
*
* @param ctx, the context in which this function is executed.
*/
default void endSecondInput(NonPartitionedContext ctx) {}
} |
...