9fe285a77de5cd1a35ceb58f9295751fd3dd9e15
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 21
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type conf : Map<?,?> to conf : Map in method public submitTopology(topologyName String, conf Map, topology FlinkTopology) : void in class org.apache.flink.stormcompatibility.api.FlinkLocalCluster | From | To | |
| Change Parameter Type conf : Map<?,?> to conf : Map in method public submitTopologyWithOpts(topologyName String, conf Map, topology FlinkTopology, submitOpts SubmitOptions) : void in class org.apache.flink.stormcompatibility.api.FlinkLocalCluster | From | To | |
| Rename Variable | 1 | ||
| Rename Variable localFile : String to inputFile : String in method private getTextDataStream(env StreamExecutionEnvironment) : DataStream<String> in class org.apache.flink.stormcompatibility.excamation.ExclamationWithStormSpout | From | To | |
| Extract Variable | 8 | ||
| Extract Variable taskContext : StreamingRuntimeContext in method public testCancel() : void from class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapperTest | From | To | |
| Extract Variable taskContext : StreamingRuntimeContext in method public runAndExecuteTest1() : void from class org.apache.flink.stormcompatibility.wrappers.FiniteStormSpoutWrapperTest | From | To | |
| Extract Variable taskContext : StreamingRuntimeContext in method public runAndExecuteTest2() : void from class org.apache.flink.stormcompatibility.wrappers.FiniteStormSpoutWrapperTest | From | To | |
| Extract Variable taskContext : StreamingRuntimeContext in method public testRunExecuteFixedNumber() : void from class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapperTest | From | To | |
| Extract Variable taskContext : StreamingRuntimeContext in method public testOpen() : void from class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapperTest | From | To | |
| Extract Variable taskContext : StreamingRuntimeContext in method public testOpenSink() : void from class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapperTest | From | To | |
| Extract Variable taskContext : StreamingRuntimeContext in method public testRunExecute() : void from class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapperTest | From | To | |
| Extract Variable taskContext : StreamingRuntimeContext in method public testRunExecuteCancelInfinite() : void from class org.apache.flink.stormcompatibility.wrappers.StormSpoutWrapperTest | From | To |