|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT> in method package ReadWriteContextImpl(keyedStateBackend KeyedStateBackend<KS>, function KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>, broadcastStates Map<MapStateDescriptor<?,?>,BroadcastState<?,?>>, timerService TimerService) in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperator.ReadWriteContextImpl |
From |
To |
|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT> in method public CoBroadcastWithKeyedOperator(function KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>, broadcastStateDescriptors List<MapStateDescriptor<?,?>>) in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperator |
From |
To |
|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT> in method package OnTimerContextImpl(function KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>, broadcastStates Map<MapStateDescriptor<?,?>,BroadcastState<?,?>>, timerService TimerService) in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperator.OnTimerContextImpl |
From |
To |
|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT> in method public process(function KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>, outTypeInfo TypeInformation<OUT>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.BroadcastConnectedStream |
From |
To |
|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> in method private getInitializedTestHarness(keyTypeInfo TypeInformation<KEY>, keyKeySelector KeySelector<IN1,KEY>, function KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT>) : TwoInputStreamOperatorTestHarness<IN1,IN2,OUT> in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest |
From |
To |
|
Change Parameter Type ctx : Context to ctx : KeyedContext in method public processBroadcastElement(value Integer, ctx KeyedContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithBroadcastState |
From |
To |
|
Change Parameter Type ctx : Context to ctx : KeyedContext in method public processBroadcastElement(value Integer, ctx KeyedContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithTimerOnKeyed |
From |
To |
|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT> in method package ReadOnlyContextImpl(function KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>, broadcastStates Map<MapStateDescriptor<?,?>,BroadcastState<?,?>>, timerService TimerService) in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperator.ReadOnlyContextImpl |
From |
To |
|
Change Parameter Type ctx : Context to ctx : KeyedContext in method public processBroadcastElement(value Integer, ctx KeyedContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithSideOutput |
From |
To |
|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> in method private getInitializedTestHarness(keyTypeInfo TypeInformation<KEY>, keyKeySelector KeySelector<IN1,KEY>, function KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT>, maxParallelism int, numTasks int, taskIdx int) : TwoInputStreamOperatorTestHarness<IN1,IN2,OUT> in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest |
From |
To |
|
Change Parameter Type ctx : Context to ctx : KeyedContext in method public processBroadcastElement(value String, ctx KeyedContext, out Collector<String>) : void in class org.apache.flink.streaming.api.DataStreamTest.TestBroadcastProcessFunction |
From |
To |
|
Change Parameter Type function : KeyedBroadcastProcessFunction<IN1,IN2,OUT> to function : KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT> in method private getInitializedTestHarness(keyTypeInfo TypeInformation<KEY>, keyKeySelector KeySelector<IN1,KEY>, function KeyedBroadcastProcessFunction<KEY,IN1,IN2,OUT>, maxParallelism int, numTasks int, taskIdx int, initState OperatorStateHandles) : TwoInputStreamOperatorTestHarness<IN1,IN2,OUT> in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest |
From |
To |
|
Change Parameter Type ctx : Context to ctx : KeyedContext in method public processBroadcastElement(value Integer, ctx KeyedContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.TestFunctionWithOutput |
From |
To |