|
Change Parameter Type broadcastStateDescriptor : MapStateDescriptor<K,V> to broadcastStateDescriptors : List<MapStateDescriptor<?,?>> in method protected BroadcastConnectedStream(env StreamExecutionEnvironment, input1 DataStream<IN1>, input2 BroadcastStream<IN2>, broadcastStateDescriptors List<MapStateDescriptor<?,?>>) in class org.apache.flink.streaming.api.datastream.BroadcastConnectedStream |
From |
To |
|
Change Parameter Type broadcastStateDescriptor : MapStateDescriptor<K,V> to broadcastStateDescriptors : MapStateDescriptor<?,?>... in method protected BroadcastStream(env StreamExecutionEnvironment, input DataStream<T>, broadcastStateDescriptors MapStateDescriptor<?,?>...) in class org.apache.flink.streaming.api.datastream.BroadcastStream |
From |
To |
|
Change Parameter Type broadcastStream : BroadcastStream<R,K,V> to broadcastStream : BroadcastStream<R> in method public connect(broadcastStream BroadcastStream<R>) : BroadcastConnectedStream<T,R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type input2 : BroadcastStream<IN2,K,V> to input2 : BroadcastStream<IN2> in method protected BroadcastConnectedStream(env StreamExecutionEnvironment, input1 DataStream<IN1>, input2 BroadcastStream<IN2>, broadcastStateDescriptors List<MapStateDescriptor<?,?>>) in class org.apache.flink.streaming.api.datastream.BroadcastConnectedStream |
From |
To |
|
Change Parameter Type broadcastStateDescriptor : MapStateDescriptor<K,V> to broadcastStateDescriptors : MapStateDescriptor<?,?>... in method public broadcast(broadcastStateDescriptors MapStateDescriptor<?,?>...) : BroadcastStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type MapStateDescriptor<K,V> to List<MapStateDescriptor<?,?>> in method public getBroadcastStateDescriptor() : List<MapStateDescriptor<?,?>> in class org.apache.flink.streaming.api.datastream.BroadcastStream |
From |
To |
|
Change Return Type BroadcastStream<T,K,V> to BroadcastStream<T> in method public broadcast(broadcastStateDescriptors MapStateDescriptor<?,?>...) : BroadcastStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type BroadcastConnectedStream<T,R,K,V> to BroadcastConnectedStream<T,R> in method public connect(broadcastStream BroadcastStream<R>) : BroadcastConnectedStream<T,R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type BroadcastStream<IN2,K,V> to BroadcastStream<IN2> in method public getSecondInput() : BroadcastStream<IN2> in class org.apache.flink.streaming.api.datastream.BroadcastConnectedStream |
From |
To |
|
Rename Parameter broadcastStateDescriptor : MapStateDescriptor<K,V> to broadcastStateDescriptors : MapStateDescriptor<?,?>... in method public broadcast(broadcastStateDescriptors MapStateDescriptor<?,?>...) : BroadcastStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Parameter broadcastStateDescriptor : MapStateDescriptor<K,V> to broadcastStateDescriptors : List<MapStateDescriptor<?,?>> in method protected BroadcastConnectedStream(env StreamExecutionEnvironment, input1 DataStream<IN1>, input2 BroadcastStream<IN2>, broadcastStateDescriptors List<MapStateDescriptor<?,?>>) in class org.apache.flink.streaming.api.datastream.BroadcastConnectedStream |
From |
To |
|
Rename Parameter broadcastStateDescriptor : MapStateDescriptor<K,V> to broadcastStateDescriptors : MapStateDescriptor<?,?>... in method protected BroadcastStream(env StreamExecutionEnvironment, input DataStream<T>, broadcastStateDescriptors MapStateDescriptor<?,?>...) in class org.apache.flink.streaming.api.datastream.BroadcastStream |
From |
To |