|
Move Method public testFieldsGroupingOnMultipleBoltOutputStreams() : void from class org.apache.flink.storm.api.FlinkTopologyBuilderTest to public testFieldsGroupingOnMultipleBoltOutputStreams() : void from class org.apache.flink.storm.api.FlinkTopologyTest |
From |
To |
|
Move Method public testUndeclaredStream() : void from class org.apache.flink.storm.api.FlinkTopologyBuilderTest to public testUndeclaredStream() : void from class org.apache.flink.storm.api.FlinkTopologyTest |
From |
To |
|
Move Method public testUnknowBolt() : void from class org.apache.flink.storm.api.FlinkTopologyBuilderTest to public testUnknowBolt() : void from class org.apache.flink.storm.api.FlinkTopologyTest |
From |
To |
|
Move Method package getStormTopology() : StormTopology from class org.apache.flink.storm.api.FlinkTopologyBuilder to public getStormTopology() : StormTopology from class org.apache.flink.storm.api.FlinkTopology |
From |
To |
|
Move Method public testUnknowSpout() : void from class org.apache.flink.storm.api.FlinkTopologyBuilderTest to public testUnknowSpout() : void from class org.apache.flink.storm.api.FlinkTopologyTest |
From |
To |
|
Move Method public testFieldsGroupingOnMultipleSpoutOutputStreams() : void from class org.apache.flink.storm.api.FlinkTopologyBuilderTest to public testFieldsGroupingOnMultipleSpoutOutputStreams() : void from class org.apache.flink.storm.api.FlinkTopologyTest |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public main(args String[]) : void in class org.apache.flink.storm.exclamation.ExclamationLocal |
From |
To |
|
Change Variable Type topology : FlinkTopology to builder : TopologyBuilder in method public testDefaultParallelism() : void in class org.apache.flink.storm.api.FlinkTopologyTest |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method protected testProgram() : void in class org.apache.flink.storm.tests.StormFieldsGroupingITCase |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public main(args String[]) : void in class org.apache.flink.storm.wordcount.WordCountLocal |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public main(args String[]) : void in class org.apache.flink.storm.wordcount.WordCountRemoteByClient |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public main(args String[]) : void in class org.apache.flink.storm.wordcount.WordCountLocalByName |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public main(args String[]) : void in class org.apache.flink.storm.split.SplitStreamSpoutLocal |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public buildTopology(indexOrName boolean) : TopologyBuilder in class org.apache.flink.storm.wordcount.WordCountTopology |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public main(args String[]) : void in class org.apache.flink.storm.split.SplitStreamBoltLocal |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public main(args String[]) : void in class org.apache.flink.storm.wordcount.WordCountRemoteBySubmitter |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public buildTopology() : TopologyBuilder in class org.apache.flink.storm.exclamation.ExclamationTopology |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public buildTopology() : TopologyBuilder in class org.apache.flink.storm.split.SplitSpoutTopology |
From |
To |
|
Change Variable Type builder : FlinkTopologyBuilder to builder : TopologyBuilder in method public buildTopology() : TopologyBuilder in class org.apache.flink.storm.split.SplitBoltTopology |
From |
To |