flink 8b898cd342faa9efaa14f436bedaee11e6389252

8b898cd342faa9efaa14f436bedaee11e6389252

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 6

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	2
	Change Parameter Type state : Map<String,String> to state : Map<Long,String> in method package CheckingKeyedSingleBroadcastFunction(state Map<Long,String>) in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedSingleBroadcastFunction	From	To
	Change Parameter Type secondState : Map<String,String> to secondState : Map<String,Long> in method package CheckingKeyedBroadcastFunction(firstState Map<Long,Long>, secondState Map<String,Long>) in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedBroadcastFunction	From	To
	Change Variable Type	6
	Change Variable Type expectedSecondState : Map<String,String> to expectedSecondState : Map<String,Long> in method public testSavepoint() : void in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase	From	To
	Change Variable Type entry : Map.Entry<String,String> to entry : Map.Entry<String,Long> in method public processElement(value Tuple2<Long,Long>, ctx ReadOnlyContext, out Collector<Tuple2<Long,Long>>) : void in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedBroadcastFunction	From	To
	Change Variable Type entry : Map.Entry<String,String> to entry : Map.Entry<Long,String> in method public processElement(value Tuple2<Long,Long>, ctx ReadOnlyContext, out Collector<Tuple2<Long,Long>>) : void in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedSingleBroadcastFunction	From	To
	Change Variable Type actualState : Map<String,String> to actualState : Map<Long,String> in method public processElement(value Tuple2<Long,Long>, ctx ReadOnlyContext, out Collector<Tuple2<Long,Long>>) : void in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedSingleBroadcastFunction	From	To
	Change Variable Type actualSecondState : Map<String,String> to actualSecondState : Map<String,Long> in method public processElement(value Tuple2<Long,Long>, ctx ReadOnlyContext, out Collector<Tuple2<Long,Long>>) : void in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedBroadcastFunction	From	To
	Change Variable Type expectedThirdState : Map<String,String> to expectedThirdState : Map<Long,String> in method public testSavepoint() : void in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase	From	To
	Change Attribute Type	6
	Change Attribute Type stateDesc : MapStateDescriptor<String,String> to stateDesc : MapStateDescriptor<Long,String> in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckpointingKeyedSingleBroadcastFunction	From	To
	Change Attribute Type secondStateDesc : MapStateDescriptor<String,String> to secondStateDesc : MapStateDescriptor<String,Long> in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedBroadcastFunction	From	To
	Change Attribute Type expectedSecondState : Map<String,String> to expectedSecondState : Map<String,Long> in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedBroadcastFunction	From	To
	Change Attribute Type expectedState : Map<String,String> to expectedState : Map<Long,String> in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedSingleBroadcastFunction	From	To
	Change Attribute Type secondStateDesc : MapStateDescriptor<String,String> to secondStateDesc : MapStateDescriptor<String,Long> in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckpointingKeyedBroadcastFunction	From	To
	Change Attribute Type stateDesc : MapStateDescriptor<String,String> to stateDesc : MapStateDescriptor<Long,String> in class org.apache.flink.test.checkpointing.utils.StatefulJobWBroadcastStateMigrationITCase.CheckingKeyedSingleBroadcastFunction	From	To