0d6040b1f44e3884b97e8eaef063c25a663c52cc
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 2 | ||
Change Parameter Type typeSerializer : TypeSerializer<STATE> to valueStateDescriptor : ValueStateDescriptor<STATE> in method public ArtificialValueStateBuilder(stateName String, stateValueGenerator JoinFunction<IN,STATE,STATE>, valueStateDescriptor ValueStateDescriptor<STATE>) in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialValueStateBuilder | From | To | |
Change Parameter Type typeSerializer : TypeSerializer<STATE> to listStateDescriptor : ListStateDescriptor<STATE> in method public ArtificialListStateBuilder(stateName String, keyedStateGenerator JoinFunction<IN,Iterable<STATE>,List<STATE>>, operatorStateGenerator JoinFunction<IN,Iterable<STATE>,List<STATE>>, listStateDescriptor ListStateDescriptor<STATE>) in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialListStateBuilder | From | To | |
Rename Variable | 1 | ||
Rename Variable typeSerializer : TypeSerializer<STATE> to stateClass : Class<STATE> in method package createArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, inputAndOldStateToNewState JoinFunction<IN,STATE,STATE>, stateSerializers List<TypeSerializer<STATE>>, stateClasses List<Class<STATE>>) : ArtificialKeyedStateMapper<IN,OUT> in class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
Rename Attribute | 1 | ||
Rename Attribute typeSerializer : TypeSerializer<STATE> to listStateDescriptor : ListStateDescriptor<STATE> in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialListStateBuilder | From | To | |
Change Variable Type | 1 | ||
Change Variable Type typeSerializer : TypeSerializer<STATE> to stateClass : Class<STATE> in method package createArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, inputAndOldStateToNewState JoinFunction<IN,STATE,STATE>, stateSerializers List<TypeSerializer<STATE>>, stateClasses List<Class<STATE>>) : ArtificialKeyedStateMapper<IN,OUT> in class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type typeSerializer : TypeSerializer<STATE> to listStateDescriptor : ListStateDescriptor<STATE> in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialListStateBuilder | From | To | |
Rename Parameter | 2 | ||
Rename Parameter typeSerializer : TypeSerializer<STATE> to valueStateDescriptor : ValueStateDescriptor<STATE> in method public ArtificialValueStateBuilder(stateName String, stateValueGenerator JoinFunction<IN,STATE,STATE>, valueStateDescriptor ValueStateDescriptor<STATE>) in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialValueStateBuilder | From | To | |
Rename Parameter typeSerializer : TypeSerializer<STATE> to listStateDescriptor : ListStateDescriptor<STATE> in method public ArtificialListStateBuilder(stateName String, keyedStateGenerator JoinFunction<IN,Iterable<STATE>,List<STATE>>, operatorStateGenerator JoinFunction<IN,Iterable<STATE>,List<STATE>>, listStateDescriptor ListStateDescriptor<STATE>) in class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialListStateBuilder | From | To |