9b7e429246d149d02a899071b71e7ee9d321b9f4
Files Diff
- Added: 15
- Removed: 9
- Renamed: 0
- Modified: 54
Link to commit
Third party dependencies:
| Dependency Action | |
|---|---|
| Added | |
| org.apache.flink:flink-shaded-guava:18.0-2.0 | |
| junit:junit:4.12 | |
| org.apache.zookeeper:zookeeper:3.4.10 | |
| org.xerial.snappy:snappy-java:1.1.4 | |
| org.joda:joda-convert:1.7 | |
| org.apache.flink:flink-shaded-asm:5.0.4-2.0 | |
| com.github.scopt:scopt_2.11:3.5.0 | |
| org.scala-lang:scala-reflect:2.11.12 | |
| com.typesafe.akka:akka-slf4j_2.11:2.4.20 | |
| com.101tec:zkclient:0.7 | |
| com.typesafe.akka:akka-remote_2.11:2.4.20 | |
| com.typesafe.akka:akka-protobuf_2.11:2.4.20 | |
| log4j:log4j:1.2.17 | |
| com.amazonaws:aws-java-sdk-core:1.11.95 | |
| org.apache.commons:commons-lang3:3.3.2 | |
| org.scala-lang:scala-library:2.11.12 | |
| org.scala-lang:scala-compiler:2.11.12 | |
| org.tukaani:xz:1.5 | |
| com.amazonaws:aws-java-sdk-kms:1.11.95 | |
| org.apache.commons:commons-math3:3.5 | |
| commons-collections:commons-collections:3.2.2 | |
| commons-configuration:commons-configuration:1.7 | |
| org.slf4j:slf4j-log4j12:1.7.7 | |
| com.typesafe.akka:akka-stream_2.11:2.4.20 | |
| commons-io:commons-io:2.4 | |
| org.apache.httpcomponents:httpclient:4.5.3 | |
| org.apache.httpcomponents:httpcore:4.4.6 | |
| commons-codec:commons-codec:1.10 | |
| com.typesafe.akka:akka-actor_2.11:2.4.20 | |
| com.amazonaws:aws-java-sdk-s3:1.11.95 | |
| org.javassist:javassist:3.18.2-GA | |
| org.apache.commons:commons-compress:1.4.1 | |
| org.clapper:grizzled-slf4j_2.11:1.0.2 | |
| joda-time:joda-time:2.5 | |
| com.google.code.findbugs:jsr305:1.3.9 | |
| org.scalatest:scalatest_2.11:2.2.2 | |
| org.reflections:reflections:0.9.10 | |
| org.apache.flink:flink-shaded-jackson:2.7.9-2.0 | |
| com.typesafe.akka:akka-camel_2.11:2.4.20 | |
| commons-logging:commons-logging:1.1.3 | |
| org.apache.flink:flink-shaded-netty:4.0.27.Final-2.0 | |
| com.typesafe:config:1.3.0 | |
| org.hamcrest:hamcrest-core:1.3 | |
| org.objenesis:objenesis:2.1 | |
| org.slf4j:slf4j-api:1.7.7 | |
| commons-cli:commons-cli:1.3.1 | |
| org.apache.avro:avro:1.8.2 | |
| com.typesafe.akka:akka-testkit_2.11:2.4.20 | |
| com.esotericsoftware.kryo:kryo:2.24.0 |
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 2 | ||
| Move And Rename Method public PythonFlatMapFunction(fun FlatMapFunction<PyObject,PyObject>) from class org.apache.flink.streaming.python.api.functions.PythonFlatMapFunction to package AbstractPythonUDF(fun F) from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Move And Rename Method public PythonApplyFunction(fun WindowFunction<PyObject,PyObject,Object,W>) from class org.apache.flink.streaming.python.api.functions.PythonApplyFunction to package AbstractPythonUDF(fun F) from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Change Parameter Type | 5 | ||
| Change Parameter Type record : PyObject to record : Object in method public collect(record Object) : void in class org.apache.flink.streaming.python.util.PythonCollector | From | To | |
| Change Parameter Type fun : FlatMapFunction<PyObject,PyObject> to fun : F in method package AbstractPythonUDF(fun F) in class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Change Parameter Type fun : WindowFunction<PyObject,PyObject,Object,W> to fun : WindowFunction<PyObject,Object,Object,W> in method public apply(fun WindowFunction<PyObject,Object,Object,W>) : PythonSingleOutputStreamOperator in class org.apache.flink.streaming.python.api.datastream.PythonWindowedStream | From | To | |
| Change Parameter Type fun : WindowFunction<PyObject,PyObject,Object,W> to fun : F in method package AbstractPythonUDF(fun F) in class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Change Parameter Type flat_mapper : FlatMapFunction<PyObject,PyObject> to flat_mapper : FlatMapFunction<PyObject,Object> in method public flat_map(flat_mapper FlatMapFunction<PyObject,Object>) : PythonDataStream<SingleOutputStreamOperator<PyObject>> in class org.apache.flink.streaming.python.api.datastream.PythonDataStream | From | To | |
| Move Method | 6 | ||
| Move Method public get_execution_environment() : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment to public get_execution_environment() : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonEnvironmentFactory | From | To | |
| Move Method public create_remote_execution_environment(host String, port int, config Configuration, jar_files String...) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment to public create_remote_execution_environment(host String, port int, config Configuration, jar_files String...) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonEnvironmentFactory | From | To | |
| Move Method public create_local_execution_environment(parallelism int, config Configuration) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment to public create_local_execution_environment(parallelism int, config Configuration) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonEnvironmentFactory | From | To | |
| Move Method public create_remote_execution_environment(host String, port int, parallelism int, jar_files String...) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment to public create_remote_execution_environment(host String, port int, parallelism int, jar_files String...) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonEnvironmentFactory | From | To | |
| Move Method public create_remote_execution_environment(host String, port int, jar_files String...) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment to public create_remote_execution_environment(host String, port int, jar_files String...) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonEnvironmentFactory | From | To | |
| Move Method public create_local_execution_environment(config Configuration) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment to public create_local_execution_environment(config Configuration) : PythonStreamExecutionEnvironment from class org.apache.flink.streaming.python.api.environment.PythonEnvironmentFactory | From | To | |
| Pull Up Attribute | 6 | ||
| Pull Up Attribute private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.PythonGeneratorFunction to private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Attribute private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.PythonFlatMapFunction to private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Attribute private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.PythonSinkFunction to private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Attribute private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.PythonApplyFunction to private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Attribute private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.PythonMapFunction to private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Attribute private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.PythonFilterFunction to private serFun : byte[] from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.streaming.python.api.environment.PythonEnvironmentFactory from class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.python.api.datastream.PythonObjectInputStream2 moved and renamed to org.apache.flink.streaming.python.util.serialization.SerializationUtils.SerialVersionOverridingPythonObjectInputStream | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type fileUri : URI to fileUri : Path in method private cleanupDistributedFiles() : void in class org.apache.flink.streaming.python.api.environment.PythonStreamExecutionEnvironment | From | To | |
| Rename Method | 1 | ||
| Rename Method public print() : void renamed to public output() : void in class org.apache.flink.streaming.python.api.datastream.PythonDataStream | From | To | |
| Pull Up Method | 10 | ||
| Pull Up Method public open(parameters Configuration) : void from class org.apache.flink.streaming.python.api.functions.PythonSinkFunction to public open(parameters Configuration) : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.python.api.functions.PythonFlatMapFunction to public close() : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.python.api.functions.PythonMapFunction to public close() : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public open(parameters Configuration) : void from class org.apache.flink.streaming.python.api.functions.PythonGeneratorFunction to public open(parameters Configuration) : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.python.api.functions.PythonFilterFunction to public close() : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public open(parameters Configuration) : void from class org.apache.flink.streaming.python.api.functions.PythonFilterFunction to public open(parameters Configuration) : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.python.api.functions.PythonApplyFunction to public close() : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.python.api.functions.PythonGeneratorFunction to public close() : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public open(config Configuration) : void from class org.apache.flink.streaming.python.api.functions.PythonMapFunction to public open(parameters Configuration) : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.python.api.functions.PythonSinkFunction to public close() : void from class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Rename Variable | 2 | ||
| Rename Variable resultClassDescriptor : ObjectStreamClass to readClassDescriptor : ObjectStreamClass in method protected readClassDescriptor() : ObjectStreamClass in class org.apache.flink.streaming.python.util.serialization.SerializationUtils.SerialVersionOverridingPythonObjectInputStream | From | To | |
| Rename Variable streamSUID : long to readSUID : long in method protected readClassDescriptor() : ObjectStreamClass in class org.apache.flink.streaming.python.util.serialization.SerializationUtils.SerialVersionOverridingPythonObjectInputStream | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Object to X in method public deserializeObject(bytes byte[]) : X in class org.apache.flink.streaming.python.util.serialization.SerializationUtils | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.python.api.functions.AbstractPythonUDF from classes [org.apache.flink.streaming.python.api.functions.PythonApplyFunction, org.apache.flink.streaming.python.api.functions.PythonFilterFunction, org.apache.flink.streaming.python.api.functions.PythonFlatMapFunction, org.apache.flink.streaming.python.api.functions.PythonGeneratorFunction, org.apache.flink.streaming.python.api.functions.PythonMapFunction, org.apache.flink.streaming.python.api.functions.PythonSinkFunction] | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter config : Configuration to parameters : Configuration in method public open(parameters Configuration) : void in class org.apache.flink.streaming.python.api.functions.AbstractPythonUDF | From | To | |
| Rename Parameter parameters : Configuration to config : Configuration in method public open(config Configuration) : void in class org.apache.flink.streaming.python.api.functions.PythonApplyFunction | From | To |