THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * This interface represents the context associated with all operations must be applied to all * partitions. */ public interface NonPartitionedContext<OUT> extends RuntimeContext { /** * Apply a function to all partitions. For keyed stream, it will apply to all keys. For * non-keyed stream, it will apply to single partition. */ void applyToAllPartitions(ApplyPartitionFunction<OUT> applyPartitionFunction); } /** A function to be applied to all partitions . */ @FunctionalInterface public interface ApplyPartitionFunction<OUT> { /** * The actual method to be applied to each partition. * * @param collector to output data. * @param ctx runtime context in which this function is executed. */ void apply(Collector<OUT> collector, RuntimeContext ctx) throws Exception; } /** * This interface represents the context associated with all operations must be applied to all * partitions with two outputs. */ public interface TwoOutputNonPartitionedContext<OUT1, OUT2> extends RuntimeContext { /** * Apply a function to all partitions. For keyed stream, it will apply to all keys. For * non-keyed stream, it will apply to single partition. */ void applyToAllPartitions(TwoOutputNonPartitionedContext<OUT1, OUT2> applyPartitionFunction); } /** A function to be applied to all partitions with two outputs.. */ @FunctionalInterface public interface TwoOutputApplyPartitionFunction<OUT1, OUT2> { /** * The actual method to be applied to each partition. * * @param firstOutput to emit record to first output. * @param secondOutput to emit record to second output. * @param ctx runtime context in which this function is executed. */ void apply(Collector<OUT1> firstOutput, Collector<OUT2> secondOutput, RuntimeContext ctx) throws Exception; } |
...