THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
/** This class contains all logical related to process and emit records to two outputs. */
public interface TwoOutputStreamProcessFunction<IN, OUT1, OUT2> extends ProcessFunction {
/**
* Process and emit record to the first/second output through {@link Collector}s.
*
* @param record to process.
* @param output1 to emit processed records to the first output.
* @param output2 to emit processed records to the second output.
* @param ctx, runtime context in which this function is executed.
*/
void processRecord(
IN record, Collector<OUT1> output1, Collector<OUT2> output2, RuntimeContext ctx);
/**
* This is a life-cycle method indicates that this function will no longer receive any input
* data. This allowing the ProcessFunction to emit results at once rather than upon each record.
*
* @param output1 to emit record to the first output.
* @param output2 to emit record to the second output.
* @param ctx, runtime context in which this function is executed.
*/
default void endInput(
Collector<OUT1> output1, Collector<OUT2> output2, RuntimeContext ctx) {}
} |
...
RuntimeContext contains information about the context in which process functions are executed. It is currently just an empty interface but will be expanded later, such as supporting access to state, registering timers, etc. This part will be elaborated in the subsequent sub-FLIPs.
We can see that each process function provides the life-cycle hook for endInput. The runtime engine will call back this method after processing all data of this input, providing the final opportunity to send data to downstream. This is crucial for implementing something like full-aggregation window.
...