|
Change Parameter Type ctx : KeyedContext to ctx : Context in method public processBroadcastElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithSideOutput |
From |
To |
|
Change Parameter Type ctx : KeyedReadOnlyContext to ctx : ReadOnlyContext in method public processElement(value String, ctx ReadOnlyContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithSideOutput |
From |
To |
|
Change Parameter Type ctx : KeyedReadOnlyContext to ctx : ReadOnlyContext in method public processElement(value Long, ctx ReadOnlyContext, out Collector<String>) : void in class org.apache.flink.test.streaming.runtime.BroadcastStateITCase.TestBroadcastProcessFunction |
From |
To |
|
Change Parameter Type ctx : KeyedReadOnlyContext to ctx : ReadOnlyContext in method public processElement(value String, ctx ReadOnlyContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.StatefulFunctionWithKeyedStateAccessedOnBroadcast |
From |
To |
|
Change Parameter Type ctx : KeyedContext to ctx : Context in method public processBroadcastElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.StatefulFunctionWithKeyedStateAccessedOnBroadcast |
From |
To |
|
Change Parameter Type ctx : KeyedContext to ctx : Context in method public processBroadcastElement(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.test.streaming.runtime.BroadcastStateITCase.TestBroadcastProcessFunction |
From |
To |
|
Change Parameter Type ctx : KeyedReadOnlyContext to ctx : ReadOnlyContext in method public processElement(value String, ctx ReadOnlyContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithTimerOnKeyed |
From |
To |
|
Change Parameter Type ctx : KeyedContext to ctx : Context in method public processBroadcastElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithTimerOnKeyed |
From |
To |
|
Change Parameter Type ctx : KeyedReadOnlyContext to ctx : ReadOnlyContext in method public processElement(value String, ctx ReadOnlyContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.TestFunctionWithOutput |
From |
To |
|
Change Parameter Type ctx : KeyedContext to ctx : Context in method public processBroadcastElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.TestFunctionWithOutput |
From |
To |
|
Change Parameter Type ctx : KeyedReadOnlyContext to ctx : ReadOnlyContext in method public processElement(value String, ctx ReadOnlyContext, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithBroadcastState |
From |
To |
|
Change Parameter Type ctx : KeyedContext to ctx : Context in method public processBroadcastElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest.FunctionWithBroadcastState |
From |
To |