82d6236173093b7e035a21360c7b69c67fd6ae62
Files Diff
- Added: 1
- Removed: 2
- Renamed: 0
- Modified: 33
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public testJobWithoutObjectReuse() : void renamed to public testJob() : void in class org.apache.flink.streaming.util.StreamingProgramTestBase | From | To | |
| Rename Method public setAsContext() : void renamed to public disableAllContextAndOtherEnvironments() : void in class org.apache.flink.api.java.ScalaShellRemoteEnvironment | From | To | |
| Pull Up Method | 1 | ||
| Pull Up Method public execute() : JobExecutionResult from class org.apache.flink.streaming.api.environment.LocalStreamEnvironment to public execute() : JobExecutionResult from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type cluster : FlinkLocalCluster to clusterFactory : LocalClusterFactory in method public initialize(clusterFactory LocalClusterFactory) : void in class org.apache.flink.stormcompatibility.api.FlinkLocalCluster | From | To | |
| Rename Variable | 1 | ||
| Rename Variable result : JobExecutionResult to jobGraph : JobGraph in method public execute(jobName String) : JobExecutionResult in class org.apache.flink.streaming.api.environment.LocalStreamEnvironment | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.stormcompatibility.api.StormTestBase from classes [org.apache.flink.stormcompatibility.exclamation.ExclamationWithStormBoltITCase, org.apache.flink.stormcompatibility.exclamation.ExclamationWithStormSpoutITCase, org.apache.flink.stormcompatibility.exclamation.StormExclamationLocalITCase, org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountITCase, org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountPojoITCase, org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountWithNamesITCase, org.apache.flink.stormcompatibility.wordcount.SpoutSourceWordCountITCase, org.apache.flink.stormcompatibility.wordcount.StormWordCountLocalITCase, org.apache.flink.stormcompatibility.wordcount.StormWordCountLocalNamedITCase] | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute currentCluster : FlinkLocalCluster to currentFactory : LocalClusterFactory in class org.apache.flink.stormcompatibility.api.FlinkLocalCluster | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type result : JobExecutionResult to jobGraph : JobGraph in method public execute(jobName String) : JobExecutionResult in class org.apache.flink.streaming.api.environment.LocalStreamEnvironment | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type currentCluster : FlinkLocalCluster to currentFactory : LocalClusterFactory in class org.apache.flink.stormcompatibility.api.FlinkLocalCluster | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter conf : Configuration to config : Configuration in method public LocalStreamEnvironment(config Configuration) in class org.apache.flink.streaming.api.environment.LocalStreamEnvironment | From | To | |
| Rename Parameter cluster : FlinkLocalCluster to clusterFactory : LocalClusterFactory in method public initialize(clusterFactory LocalClusterFactory) : void in class org.apache.flink.stormcompatibility.api.FlinkLocalCluster | From | To |