34353f6658e9a4dd50ad860e17eee94804b76ccb
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 11
Link to commit
Third party dependencies:
| Dependency Action | |
|---|---|
| Added | |
| com.github.scopt:scopt_2.10:3.2.0 | |
| org.apache.avro:avro:1.7.6 | |
| org.eclipse.jetty:jetty-servlet:8.0.0.M1 | |
| org.apache.hadoop:hadoop-common:2.2.0 | |
| org.eclipse.jetty:jetty-security:8.0.0.M1 | |
| 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 | |
| org.apache.hadoop:hadoop-core:2.2.0 | |
| org.eclipse.jetty:jetty-util:8.0.0.M1 | |
| commons-collections:commons-collections:3.2.1 | |
| com.typesafe.akka:akka-camel_2.10:2.3.7 | |
| org.apache.hadoop:hadoop-client:2.2.0 | |
| org.javassist:javassist:3.18.1-GA | |
| org.apache.hadoop:hadoop-yarn-client:2.2.0 | |
| joda-time:joda-time:2.5 | |
| com.typesafe.akka:akka-slf4j_2.10:2.3.7 | |
| org.apache.hadoop:hadoop-hdfs:2.2.0 | |
| org.ow2.asm:asm:4.0 | |
| stax:stax-api:1.0.1 | |
| org.scala-lang:scala-library:2.10.4 | |
| org.apache.avro:avro-ipc:1.7.6 | |
| com.typesafe.akka:akka-testkit_2.10:2.3.7 | |
| org.eclipse.jetty:jetty-server:8.0.0.M1 | |
| org.scala-lang:scala-reflect:2.10.4 | |
| com.typesafe.akka:akka-actor_2.10:2.3.7 | |
| org.apache.hadoop:hadoop-mapreduce-client-core:2.2.0 | |
| commons-cli:commons-cli:1.2 |
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method protected addFunction(functionName String, function Function, inTypeInfo TypeInformation<OUT>, outTypeInfo TypeInformation<R>, functionInvokable StreamInvokable<OUT,R>) : SingleOutputStreamOperator<R,?> renamed to public transform(operatorName String, outTypeInfo TypeInformation<R>, invokable StreamInvokable<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter functionName : String to operatorName : String in method public transform(operatorName String, outTypeInfo TypeInformation<R>, invokable StreamInvokable<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Rename Parameter functionInvokable : StreamInvokable<OUT,R> to invokable : StreamInvokable<OUT,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, invokable StreamInvokable<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream | From | To |