THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** This class contains all logical related to process records from two 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) {} } |
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * This class contains all logical related to process records from a broadcast stream and a * non-broadcast stream. */ public interface TwoInputBroadcastStreamProcessFunction<IN1, IN2, OUT> extends ProcessFunction { /** * Process record from non-broadcast 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 processRecordFromNonBroadcastInput(IN1 record, Collector<OUT> output, RuntimeContext ctx) throws Exception; /** * Process record from broadcast input.In general, the broadcast side is not allowed to * manipulate state and output data because it corresponds to all partitions instead of a single * partition. But you could use broadcast context to process all the partitions at once. * * @param record to process. * @param ctx, the context in which this function is executed. */ void processRecordFromBroadcastInput(IN2 record, NonPartitionedContext<OUT> ctx) throws Exception; /** * This is a life-cycle method indicates that this function will no longer receive any data from * the non-broadcast input. * * @param ctx, the context in which this function is executed. */ default void endNonBroadcastInput(NonPartitionedContext ctx) {} /** * This is a life-cycle method indicates that this function will no longer receive any data from * the broadcast input. * * @param ctx, the context in which this function is executed. */ default void endBroadcastInput(NonPartitionedContext<OUT> ctx) {} } |
...