flink fa88d9eb1b88641d6ca03b38e2058d30971c7a2f

fa88d9eb1b88641d6ca03b38e2058d30971c7a2f

Files Diff

Added: 0
Removed: 1
Renamed: 0
Modified: 5

Link to commit

com.github.scopt:scopt_2.10:3.2.0
org.clapper:grizzled-slf4j_2.10:1.0.2
org.apache.avro:avro:1.7.6
io.netty:netty-all:4.0.31.Final
org.joda:joda-convert:1.7
com.typesafe.akka:akka-remote_2.10:2.3.7
org.scala-lang:scala-compiler:2.10.4
org.scalatest:scalatest_2.10:2.2.2
commons-collections:commons-collections:3.2.1
com.typesafe.akka:akka-camel_2.10:2.3.7
org.javassist:javassist:3.18.1-GA
joda-time:joda-time:2.5
com.typesafe.akka:akka-slf4j_2.10:2.3.7
stax:stax-api:1.0.1
org.scala-lang:scala-library:2.10.4
org.apache.commons:commons-math3:3.5
org.apache.avro:avro-ipc:1.7.6
com.typesafe.akka:akka-testkit_2.10:2.3.7
org.scala-lang:scala-reflect:2.10.4
com.typesafe.akka:akka-actor_2.10:2.3.7
commons-io:commons-io:2.4
org.apache.zookeeper:zookeeper:3.4.6
com.esotericsoftware.kryo:kryo:2.24.0
commons-cli:commons-cli:1.2

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Rename Variable	1
	Rename Variable spoutWrapper : SpoutWrapper to spoutWrapperSingleOutput : SpoutWrapper<Tuple> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Return Type	1
	Change Return Type TypeInformation<?> to TypeInformation<Tuple> in method package getOutputType(streamId String) : TypeInformation<Tuple> in class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer	From	To
	Change Variable Type	11
	Change Variable Type spoutWrapper : SpoutWrapper to spoutWrapperSingleOutput : SpoutWrapper<Tuple> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type availableInputs : HashMap<String,HashMap<String,DataStream>> to availableInputs : HashMap<String,HashMap<String,DataStream<Tuple>>> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type outputStreams : HashMap<String,DataStream> to outputStreams : HashMap<String,DataStream<Tuple>> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type splitSource : SplitStream to splitSource : SplitStream<SplitStreamType<Tuple>> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type outputStream : SingleOutputStreamOperator to outputStream : SingleOutputStreamOperator<?,?> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type outType : TypeInformation<?> to outType : TypeInformation<SplitStreamType<Tuple>> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type producer : HashMap<String,DataStream> to producer : HashMap<String,DataStream<Tuple>> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type inputStream : DataStream to inputStream : DataStream<Tuple> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type op : HashMap<String,DataStream> to op : HashMap<String,DataStream<Tuple>> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Change Variable Type outType : TypeInformation<?> to outType : TypeInformation<Tuple> in method public createTopology() : FlinkTopology in class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Extract Variable	3
	Extract Variable src : DataStreamSource<Tuple> in method public createTopology() : FlinkTopology from class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Extract Variable multiStream : SingleOutputStreamOperator<SplitStreamType<Tuple>,?> in method public createTopology() : FlinkTopology from class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To
	Extract Variable outStream : SingleOutputStreamOperator<Tuple,?> in method public createTopology() : FlinkTopology from class org.apache.flink.storm.api.FlinkTopologyBuilder	From	To