|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.stormoperators.StormBoltTokenizer moved and renamed to org.apache.flink.storm.wordcount.operators.BoltTokenizer |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormSpoutCollector moved and renamed to org.apache.flink.storm.wrappers.SpoutCollector |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.StormInMemorySpout moved and renamed to org.apache.flink.storm.util.InMemorySpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.StormWordCountNamedLocal moved and renamed to org.apache.flink.storm.wordcount.WordCountLocalByName |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormFiniteSpoutWrapperTest moved and renamed to org.apache.flink.storm.wrappers.SpoutWrapperTest |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.FiniteStormSpout moved and renamed to org.apache.flink.storm.util.FiniteSpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.FiniteStormFileSpout moved and renamed to org.apache.flink.storm.util.FiniteFileSpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormSpoutCollectorTest moved and renamed to org.apache.flink.storm.wrappers.SpoutCollectorTest |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.StormFileSpout moved and renamed to org.apache.flink.storm.util.FileSpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.StormWordCountLocal moved and renamed to org.apache.flink.storm.wordcount.WordCountLocal |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.singlejoin.StormSingleJoinLocal moved and renamed to org.apache.flink.storm.split.SplitStreamBoltLocal |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.stormoperators.StormWordCountFileSpout moved and renamed to org.apache.flink.storm.wordcount.operators.WordCountFileSpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.stormoperators.StormBoltTokenizerByName moved and renamed to org.apache.flink.storm.wordcount.operators.BoltTokenizerByName |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper moved and renamed to org.apache.flink.storm.wrappers.BoltWrapper |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.FiniteStormInMemorySpout moved and renamed to org.apache.flink.storm.util.FiniteInMemorySpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.excamation.ExclamationWithStormBolt moved and renamed to org.apache.flink.storm.excamation.ExclamationWithBolt |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.StormWordCountLocalITCase moved and renamed to org.apache.flink.storm.wordcount.WordCountLocalITCase |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.FlinkStormStreamSelector moved and renamed to org.apache.flink.storm.util.StormStreamSelector |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormWrapperSetupHelper moved and renamed to org.apache.flink.storm.wrappers.WrapperSetupHelper |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.excamation.StormExclamationRemoteByClient moved and renamed to org.apache.flink.storm.wordcount.WordCountRemoteByClient |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.StormBoltPrintSink moved and renamed to org.apache.flink.storm.util.BoltPrintSink |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.StormWordCountLocalNamedITCase moved and renamed to org.apache.flink.storm.wordcount.WordCountLocalNamedITCase |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormBoltCollector moved and renamed to org.apache.flink.storm.wrappers.BoltCollector |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.StormBoltFileSink moved and renamed to org.apache.flink.storm.util.BoltFileSink |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.stormoperators.StormBoltCounter moved and renamed to org.apache.flink.storm.wordcount.operators.BoltCounter |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapperTest moved and renamed to org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormWrapperSetupHelperTest moved and renamed to org.apache.flink.storm.wrappers.WrapperSetupHelperTest |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.excamation.StormExclamationLocal moved and renamed to org.apache.flink.storm.excamation.ExclamationLocal |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.excamation.ExclamationWithStormSpout moved and renamed to org.apache.flink.storm.excamation.ExclamationWithSpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.StormWordCountRemoteBySubmitter moved and renamed to org.apache.flink.storm.split.SplitStreamSpoutLocal |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.stormoperators.StormBoltCounterByName moved and renamed to org.apache.flink.storm.wordcount.operators.BoltCounterByName |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.excamation.StormExclamationRemoteBySubmitter moved and renamed to org.apache.flink.storm.wordcount.WordCountRemoteBySubmitter |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.exclamation.ExclamationWithStormSpoutITCase moved and renamed to org.apache.flink.storm.exclamation.ExclamationWithSpoutITCase |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.AbstractStormSpout moved and renamed to org.apache.flink.storm.util.AbstractLineSpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.FlinkStormStreamSelectorTest moved and renamed to org.apache.flink.storm.util.StormStreamSelectorTest |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.util.AbstractStormBoltSink moved and renamed to org.apache.flink.storm.util.AbstractBoltSink |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wordcount.stormoperators.StormWordCountInMemorySpout moved and renamed to org.apache.flink.storm.wordcount.operators.WordCountInMemorySpout |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.exclamation.ExclamationWithStormBoltITCase moved and renamed to org.apache.flink.storm.exclamation.ExclamationWithBoltITCase |
From |
To |
|
Move And Rename Class org.apache.flink.stormcompatibility.wrappers.StormBoltCollectorTest moved and renamed to org.apache.flink.storm.wrappers.BoltCollectorTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountPojo moved to org.apache.flink.storm.wordcount.BoltTokenizerWordCountPojo |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.SpoutSourceWordCount moved to org.apache.flink.storm.wordcount.SpoutSourceWordCount |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.SpoutSourceWordCountITCase moved to org.apache.flink.storm.wordcount.SpoutSourceWordCountITCase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.SpoutSplitExample moved to org.apache.flink.storm.split.SpoutSplitExample |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.TupleOutputFormatter moved to org.apache.flink.storm.util.TupleOutputFormatter |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.SplitBoltTopology moved to org.apache.flink.storm.split.SplitBoltTopology |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.TestTopologyBuilder moved to org.apache.flink.storm.api.TestTopologyBuilder |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.stormoperators.WordCountDataPojos moved to org.apache.flink.storm.wordcount.operators.WordCountDataPojos |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wrappers.TestContext moved to org.apache.flink.storm.wrappers.TestContext |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.exclamation.util.ExclamationData moved to org.apache.flink.storm.exclamation.util.ExclamationData |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.SplitStreamType moved to org.apache.flink.storm.util.SplitStreamType |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.TestBolt moved to org.apache.flink.storm.api.TestBolt |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.FlinkTopology moved to org.apache.flink.storm.api.FlinkTopology |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector moved to org.apache.flink.storm.wrappers.AbstractStormCollector |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.excamation.stormoperators.ExclamationBolt moved to org.apache.flink.storm.excamation.operators.ExclamationBolt |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.SplitBolt moved to org.apache.flink.storm.split.SplitBolt |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.SplitSpoutTopology moved to org.apache.flink.storm.split.SplitSpoutTopology |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.OutputFormatter moved to org.apache.flink.storm.util.OutputFormatter |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.TestSpout moved to org.apache.flink.storm.api.TestSpout |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wrappers.StormTupleTest moved to org.apache.flink.storm.wrappers.StormTupleTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.FlinkTopologyBuilder moved to org.apache.flink.storm.api.FlinkTopologyBuilder |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.SimpleOutputFormatter moved to org.apache.flink.storm.util.SimpleOutputFormatter |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wrappers.SetupOutputFieldsDeclarerTest moved to org.apache.flink.storm.wrappers.SetupOutputFieldsDeclarerTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountPojoITCase moved to org.apache.flink.storm.wordcount.BoltTokenizerWordCountPojoITCase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.stormoperators.RandomSpout moved to org.apache.flink.storm.split.operators.RandomSpout |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.FlinkOutputFieldsDeclarerTest moved to org.apache.flink.storm.api.FlinkOutputFieldsDeclarerTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.FlinkSubmitter moved to org.apache.flink.storm.api.FlinkSubmitter |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.TestDummyBolt moved to org.apache.flink.storm.util.TestDummyBolt |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountITCase moved to org.apache.flink.storm.wordcount.BoltTokenizerWordCountITCase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.FlinkTopologyTest moved to org.apache.flink.storm.api.FlinkTopologyTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCount moved to org.apache.flink.storm.wordcount.BoltTokenizerWordCount |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.StormConfig moved to org.apache.flink.storm.util.StormConfig |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.SpoutSplitITCase moved to org.apache.flink.storm.split.SpoutSplitITCase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.FlinkLocalCluster moved to org.apache.flink.storm.api.FlinkLocalCluster |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountWithNamesITCase moved to org.apache.flink.storm.wordcount.BoltTokenizerWordCountWithNamesITCase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.stormoperators.WordCountDataTuple moved to org.apache.flink.storm.wordcount.operators.WordCountDataTuple |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.WordCountTopology moved to org.apache.flink.storm.wordcount.WordCountTopology |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.FlinkTopologyContextTest moved to org.apache.flink.storm.wrappers.FlinkTopologyContextTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.StormTestBase moved to org.apache.flink.storm.util.StormTestBase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.FlinkClient moved to org.apache.flink.storm.api.FlinkClient |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.BoltSplitITCase moved to org.apache.flink.storm.split.BoltSplitITCase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wrappers.StormTuple moved to org.apache.flink.storm.wrappers.StormTuple |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountWithNames moved to org.apache.flink.storm.wordcount.BoltTokenizerWordCountWithNames |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.FiniteTestSpout moved to org.apache.flink.storm.util.FiniteTestSpout |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.exclamation.StormExclamationLocalITCase moved to org.apache.flink.storm.exclamation.StormExclamationLocalITCase |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.TestSink moved to org.apache.flink.storm.util.TestSink |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.FlinkTopologyBuilderTest moved to org.apache.flink.storm.api.FlinkTopologyBuilderTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.TestDummySpout moved to org.apache.flink.storm.util.TestDummySpout |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.AbstractTest moved to org.apache.flink.storm.util.AbstractTest |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.FlinkTopologyContext moved to org.apache.flink.storm.wrappers.FlinkTopologyContext |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.wrappers.SetupOutputFieldsDeclarer moved to org.apache.flink.storm.wrappers.SetupOutputFieldsDeclarer |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.SplitStreamMapper moved to org.apache.flink.storm.util.SplitStreamMapper |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.excamation.ExclamationTopology moved to org.apache.flink.storm.excamation.ExclamationTopology |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.util.FlinkOutputFieldsDeclarer moved to org.apache.flink.storm.api.FlinkOutputFieldsDeclarer |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.split.stormoperators.VerifyAndEnrichBolt moved to org.apache.flink.storm.split.operators.VerifyAndEnrichBolt |
From |
To |
|
Move Class org.apache.flink.stormcompatibility.api.SplitStreamTypeKeySelector moved to org.apache.flink.storm.util.SplitStreamTypeKeySelector |
From |
To |
|
Change Variable Type wrapper : StormBoltWrapper<Object,Object> to wrapper : BoltWrapper<Object,Object> in method public testClose() : void in class org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Change Variable Type wrapper : StormBoltWrapper<Object,Object> to wrapper : BoltWrapper<Object,Object> in method public testOpen() : void in class org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Change Variable Type wrapper : StormBoltWrapper to wrapper : BoltWrapper in method private testWrapper(numberOfAttributes int) : void in class org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Change Variable Type declarer : FlinkOutputFieldsDeclarer to declarer : SetupOutputFieldsDeclarer in method package createTopologyContext(context StreamingRuntimeContext, spoutOrBolt IComponent, stormTopology StormTopology, stormConfig Map) : TopologyContext in class org.apache.flink.storm.wrappers.WrapperSetupHelper |
From |
To |
|
Change Variable Type wrapper : StormBoltWrapper to wrapper : BoltWrapper in method public testMultipleOutputStreams() : void in class org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Change Variable Type collector : StormSpoutCollector<?> to collector : SpoutCollector<?> in method public testSpoutStormCollector() : void in class org.apache.flink.storm.wrappers.SpoutCollectorTest |
From |
To |
|
Change Variable Type spoutWrapper : StormFiniteSpoutWrapper<Tuple1<Integer>> to spoutWrapper : SpoutWrapper<Tuple1<Integer>> in method public testCancel() : void in class org.apache.flink.storm.wrappers.SpoutWrapperTest |
From |
To |
|
Change Variable Type selector : FlinkStormStreamSelector<Object> to selector : StormStreamSelector<Object> in method public testSelector() : void in class org.apache.flink.storm.util.StormStreamSelectorTest |
From |
To |
|
Change Variable Type collector : StormBoltCollector<?> to collector : BoltCollector<?> in method public testBoltStormCollector() : void in class org.apache.flink.storm.wrappers.BoltCollectorTest |
From |
To |
|
Change Variable Type spoutWrapper : StormFiniteSpoutWrapper<?> to spoutWrapper : SpoutWrapper<?> in method public testRunExecuteFixedNumber() : void in class org.apache.flink.storm.wrappers.SpoutWrapperTest |
From |
To |
|
Change Variable Type wrapper : StormBoltWrapper<Object,Object> to wrapper : BoltWrapper<Object,Object> in method public testOpenSink() : void in class org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Change Variable Type spout : IRichSpout to spout : FiniteTestSpout in method public testRunExecuteFinite() : void in class org.apache.flink.storm.wrappers.SpoutWrapperTest |
From |
To |