flink 3a8302998d2fc7f38504c238916bc7d0dada2320

3a8302998d2fc7f38504c238916bc7d0dada2320

Files Diff

Added: 17
Removed: 0
Renamed: 0
Modified: 27

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	10
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public StormBoltWrapper(bolt IRichBolt, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper	From	To
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public FiniteStormSpoutWrapper(spout FiniteStormSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.FiniteStormSpoutWrapper	From	To
Change Parameter Type numberOfAttributes : int to numberOfAttributes : HashMap<String,Integer> in method public StormSpoutCollector(numberOfAttributes HashMap<String,Integer>, flinkContext SourceContext<OUT>) in class org.apache.flink.stormcompatibility.wrappers.StormSpoutCollector	From	To
Change Parameter Type numberOfAttributes : int to numberOfAttributes : HashMap<String,Integer> in method public StormBoltCollector(numberOfAttributes HashMap<String,Integer>, flinkOutput Collector<OUT>) in class org.apache.flink.stormcompatibility.wrappers.StormBoltCollector	From	To
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public StormSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormSpoutWrapper	From	To
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public StormBoltWrapper(bolt IRichBolt, inputSchema Fields, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper	From	To
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public AbstractStormSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.AbstractStormSpoutWrapper	From	To
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public getNumberOfAttributes(spoutOrBolt IComponent, rawOutputs Collection<String>) : HashMap<String,Integer> in class org.apache.flink.stormcompatibility.wrappers.StormWrapperSetupHelper	From	To
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public StormFiniteSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapper	From	To
Change Parameter Type rawOutput : boolean to rawOutputs : Collection<String> in method public StormFiniteSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>, numberOfInvocations int) in class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapper	From	To
Rename Variable	2
Rename Variable inputStream : Entry<GlobalStreamId,Grouping> to stormInputStream : Entry<GlobalStreamId,Grouping> in method public createTopology() : FlinkTopology in class org.apache.flink.stormcompatibility.api.FlinkTopologyBuilder	From	To
Rename Variable procDeclarer : FlinkOutputFieldsDeclarer to prodDeclarer : FlinkOutputFieldsDeclarer in method public createTopology() : FlinkTopology in class org.apache.flink.stormcompatibility.api.FlinkTopologyBuilder	From	To
Change Return Type	1
Change Return Type int to HashMap<String,Integer> in method public getNumberOfAttributes(spoutOrBolt IComponent, rawOutputs Collection<String>) : HashMap<String,Integer> in class org.apache.flink.stormcompatibility.wrappers.StormWrapperSetupHelper	From	To
Extract Variable	1
Extract Variable value : IN in method public processElement(element StreamRecord<IN>) : void from class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper	From	To
Extract Method	1
Extract Method private createSchema(numberOfAttributes int) : Fields extracted from public testDeclare() : void in class org.apache.flink.stormcompatibility.wrappers.StormOutputFieldsDeclarerTest	From	To
Change Attribute Type	4
Change Attribute Type numberOfAttributes : int to numberOfAttributes : HashMap<String,Integer> in class org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector	From	To
Change Attribute Type numberOfAttributes : int to numberOfAttributes : HashMap<String,Integer> in class org.apache.flink.stormcompatibility.wrappers.AbstractStormSpoutWrapper	From	To
Change Attribute Type outputTuple : Tuple to outputTuple : HashMap<String,Tuple> in class org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector	From	To
Change Attribute Type numberOfAttributes : int to numberOfAttributes : HashMap<String,Integer> in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper	From	To
Rename Parameter	8
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public FiniteStormSpoutWrapper(spout FiniteStormSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.FiniteStormSpoutWrapper	From	To
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public StormBoltWrapper(bolt IRichBolt, inputSchema Fields, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper	From	To
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public AbstractStormSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.AbstractStormSpoutWrapper	From	To
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public StormSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormSpoutWrapper	From	To
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public getNumberOfAttributes(spoutOrBolt IComponent, rawOutputs Collection<String>) : HashMap<String,Integer> in class org.apache.flink.stormcompatibility.wrappers.StormWrapperSetupHelper	From	To
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public StormFiniteSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapper	From	To
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public StormFiniteSpoutWrapper(spout IRichSpout, rawOutputs Collection<String>, numberOfInvocations int) in class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapper	From	To
Rename Parameter rawOutput : boolean to rawOutputs : Collection<String> in method public StormBoltWrapper(bolt IRichBolt, rawOutputs Collection<String>) in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper	From	To

3a8302998d2fc7f38504c238916bc7d0dada2320

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: