e39699f3eb41517a7035a5e626c6bb20c6b70501
Files Diff
- Added: 6
- Removed: 5
- Renamed: 0
- Modified: 35
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type input : Object to input : Tuple in method public format(input Tuple) : String in class org.apache.flink.stormcompatibility.util.TupleOutputFormatter | From | To | |
| Change Parameter Type input : Object to input : Tuple in method public format(input Tuple) : String in class org.apache.flink.stormcompatibility.util.OutputFormatter | From | To | |
| Change Parameter Type input : Object to input : Tuple in method public format(input Tuple) : String in class org.apache.flink.stormcompatibility.util.SimpleOutputFormatter | From | To | |
| Change Parameter Type collector : Collector<OUT> to ctx : SourceContext<OUT> in method public run(ctx SourceContext<OUT>) : void in class org.apache.flink.stormcompatibility.wrappers.AbstractStormSpoutWrapper | From | To | |
| Inline Method | 1 | ||
| Inline Method private testStromCollector(spoutTest boolean, numberOfAttributes int) : void inlined to public testBoltStormCollector() : void in class org.apache.flink.stormcompatibility.wrappers.StormBoltCollectorTest | From | To | |
| Rename Class | 2 | ||
| Rename Class org.apache.flink.stormcompatibility.wrappers.TestCollector renamed to org.apache.flink.stormcompatibility.wrappers.TestContext | From | To | |
| Rename Class org.apache.flink.stormcompatibility.wrappers.StormCollectorTest renamed to org.apache.flink.stormcompatibility.wrappers.StormBoltCollectorTest | From | To | |
| Change Variable Type | 6 | ||
| Change Variable Type flinkCollector : Collector to flinkCollector : Output in method public testBoltStormCollector() : void in class org.apache.flink.stormcompatibility.wrappers.StormBoltCollectorTest | From | To | |
| Change Variable Type collector : TestCollector to collector : TestContext in method public testRunExecuteCancelInfinite() : void in class org.apache.flink.stormcompatibility.wrappers.StormSpoutWrapperTest | From | To | |
| Change Variable Type taskContext : StreamTaskContext to taskContext : StreamingRuntimeContext in method private testWrapper(numberOfAttributes int) : void in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapperTest | From | To | |
| Change Variable Type collector : TestCollector to collector : TestContext in method public testRunExecute() : void in class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapperTest | From | To | |
| Change Variable Type collector : TestCollector to collector : TestContext in method public testCancel() : void in class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapperTest | From | To | |
| Change Variable Type collector : StormCollector<?> to collector : StormBoltCollector<?> in method public testBoltStormCollector() : void in class org.apache.flink.stormcompatibility.wrappers.StormBoltCollectorTest | From | To | |
| Extract Method | 1 | ||
| Extract Method public addSource(function SourceFunction<OUT>, sourceName String, typeInfo TypeInformation<OUT>) : DataStreamSource<OUT> extracted from public addSource(function SourceFunction<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type collector : StormCollector<OUT> to collector : StormSpoutCollector<OUT> in class org.apache.flink.stormcompatibility.wrappers.AbstractStormSpoutWrapper | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter collector : Collector<OUT> to ctx : SourceContext<OUT> in method public run(ctx SourceContext<OUT>) : void in class org.apache.flink.stormcompatibility.wrappers.AbstractStormSpoutWrapper | From | To |