5ac4d29609842cb086b46fd56f6e49a4287cfa1b
Files Diff
- Added: 9
- Removed: 4
- Renamed: 0
- Modified: 6
Link to commit
Third party dependencies:
| Dependency Action | |
|---|---|
| Added | |
| junit:junit:4.12 | |
| com.typesafe.akka:akka-remote_2.11:2.4.20 | |
| org.apache.flink:flink-shaded-guava:18.0-2.0 | |
| org.joda:joda-convert:1.7 | |
| com.typesafe.akka:akka-testkit_2.11:2.4.20 | |
| org.apache.zookeeper:zookeeper:3.4.10 | |
| com.esotericsoftware.kryo:kryo:2.24.0 | |
| org.scala-lang:scala-reflect:2.11.12 | |
| org.scala-lang:scala-library:2.11.12 | |
| com.typesafe.akka:akka-protobuf_2.11:2.4.20 | |
| com.typesafe.akka:akka-stream_2.11:2.4.20 | |
| com.google.guava:guava:19.0 | |
| org.slf4j:slf4j-api:1.7.7 | |
| org.apache.commons:commons-lang3:3.3.2 | |
| org.tukaani:xz:1.5 | |
| org.apache.flink:flink-shaded-asm:5.0.4-2.0 | |
| log4j:log4j:1.2.17 | |
| com.amazonaws:aws-java-sdk-core:1.11.95 | |
| com.typesafe.akka:akka-slf4j_2.11:2.4.20 | |
| commons-logging:commons-logging:1.1.3 | |
| org.apache.flink:flink-shaded-jackson-module-jsonSchema:2.7.9-3.0 | |
| org.javassist:javassist:3.19.0-GA | |
| org.reflections:reflections:0.9.10 | |
| com.google.code.findbugs:jsr305:1.3.9 | |
| org.apache.avro:avro:1.8.2 | |
| com.typesafe:config:1.3.0 | |
| org.codehaus.janino:janino:3.0.7 | |
| com.typesafe.akka:akka-camel_2.11:2.4.20 | |
| org.hamcrest:hamcrest-core:1.3 | |
| org.apache.flink:flink-shaded-netty:4.0.27.Final-2.0 | |
| org.objenesis:objenesis:2.1 | |
| com.github.scopt:scopt_2.11:3.5.0 | |
| org.apache.flink:flink-shaded-jackson:2.7.9-3.0 | |
| org.scalatest:scalatest_2.11:2.2.2 | |
| com.typesafe.akka:akka-actor_2.11:2.4.20 | |
| org.apache.commons:commons-compress:1.4.1 | |
| com.amazonaws:aws-java-sdk-s3:1.11.95 | |
| org.apache.httpcomponents:httpcore:4.4.6 | |
| commons-codec:commons-codec:1.10 | |
| joda-time:joda-time:2.5 | |
| commons-cli:commons-cli:1.3.1 | |
| commons-lang:commons-lang:2.6 | |
| com.amazonaws:aws-java-sdk-kms:1.11.95 | |
| org.codehaus.janino:commons-compiler:3.0.7 | |
| org.scala-lang.modules:scala-xml_2.11:1.0.5 | |
| commons-io:commons-io:2.4 | |
| org.apache.httpcomponents:httpclient:4.5.3 | |
| org.clapper:grizzled-slf4j_2.11:1.0.2 | |
| commons-configuration:commons-configuration:1.7 | |
| org.xerial.snappy:snappy-java:1.1.4 | |
| com.101tec:zkclient:0.7 | |
| org.slf4j:slf4j-log4j12:1.7.7 | |
| org.apache.commons:commons-math3:3.5 | |
| commons-beanutils:commons-beanutils:1.8.3 | |
| org.scala-lang:scala-compiler:2.11.12 | |
| commons-collections:commons-collections:3.2.2 |
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type artificialKeyedStateBuilder : ArtificialKeyedStateBuilder<IN> to artificialStateBuilders : ArtificialStateBuilder<IN> in method public ArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, artificialStateBuilders ArtificialStateBuilder<IN>) in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Change Parameter Type artificialKeyedStateBuilder : List<ArtificialKeyedStateBuilder<IN>> to artificialStateBuilders : List<ArtificialStateBuilder<IN>> in method public ArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, artificialStateBuilders List<ArtificialStateBuilder<IN>>) in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Move Method | 5 | ||
| Move Method private createArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, inputAndOldStateToNewState JoinFunction<IN,STATE,STATE>, stateSerializers List<TypeSerializer<STATE>>) : ArtificialKeyedStateMapper<IN,OUT> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to package createArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, inputAndOldStateToNewState JoinFunction<IN,STATE,STATE>, stateSerializers List<TypeSerializer<STATE>>) : ArtificialKeyedStateMapper<IN,OUT> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Method public setupEnvironment(env StreamExecutionEnvironment, pt ParameterTool) : void from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to package setupEnvironment(env StreamExecutionEnvironment, pt ParameterTool) : void from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Method private createTimestampExtractor(pt ParameterTool) : BoundedOutOfOrdernessTimestampExtractor<Event> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to package createTimestampExtractor(pt ParameterTool) : BoundedOutOfOrdernessTimestampExtractor<Event> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Method private createSemanticsCheckMapper(pt ParameterTool) : FlatMapFunction<Event,String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to package createSemanticsCheckMapper(pt ParameterTool) : FlatMapFunction<Event,String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Method private createEventSource(pt ParameterTool) : SourceFunction<Event> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to package createEventSource(pt ParameterTool) : SourceFunction<Event> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute | 15 | ||
| Move Attribute private SEQUENCE_GENERATOR_SRC_PAYLOAD_SIZE : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private SEQUENCE_GENERATOR_SRC_PAYLOAD_SIZE : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private ENVIRONMENT_CHECKPOINT_INTERVAL : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private ENVIRONMENT_CHECKPOINT_INTERVAL : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private SEQUENCE_GENERATOR_SRC_EVENT_TIME_MAX_OUT_OF_ORDERNESS : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private SEQUENCE_GENERATOR_SRC_EVENT_TIME_MAX_OUT_OF_ORDERNESS : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private STATE_BACKEND_CHECKPOINT_DIR : ConfigOption<String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private STATE_BACKEND_CHECKPOINT_DIR : ConfigOption<String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private SEQUENCE_GENERATOR_SRC_EVENT_TIME_CLOCK_PROGRESS : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private SEQUENCE_GENERATOR_SRC_EVENT_TIME_CLOCK_PROGRESS : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private ENVIRONMENT_RESTART_DELAY : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private ENVIRONMENT_RESTART_DELAY : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private ENVIRONMENT_PARALLELISM : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private ENVIRONMENT_PARALLELISM : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private SEQUENCE_GENERATOR_SRC_SLEEP_AFTER_ELEMENTS : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private SEQUENCE_GENERATOR_SRC_SLEEP_AFTER_ELEMENTS : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private ENVIRONMENT_MAX_PARALLELISM : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private ENVIRONMENT_MAX_PARALLELISM : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private STATE_BACKEND : ConfigOption<String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private STATE_BACKEND : ConfigOption<String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private STATE_BACKEND_ROCKS_INCREMENTAL : ConfigOption<Boolean> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private STATE_BACKEND_ROCKS_INCREMENTAL : ConfigOption<Boolean> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private STATE_BACKEND_FILE_ASYNC : ConfigOption<Boolean> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private STATE_BACKEND_FILE_ASYNC : ConfigOption<Boolean> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private SEQUENCE_GENERATOR_SRC_SLEEP_TIME : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private SEQUENCE_GENERATOR_SRC_SLEEP_TIME : ConfigOption<Long> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private TEST_SEMANTICS : ConfigOption<String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private TEST_SEMANTICS : ConfigOption<String> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Move Attribute private SEQUENCE_GENERATOR_SRC_KEYSPACE : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram to private SEQUENCE_GENERATOR_SRC_KEYSPACE : ConfigOption<Integer> from class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory from class org.apache.flink.streaming.tests.DataStreamAllroundTestProgram | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateBuilder moved and renamed to org.apache.flink.streaming.tests.artificialstate.builder.ArtificialStateBuilder | From | To | |
| Move Class | 3 | ||
| Move Class org.apache.flink.streaming.tests.artificialstate.eventpayload.ArtificialMapStateBuilder moved to org.apache.flink.streaming.tests.artificialstate.builder.ArtificialMapStateBuilder | From | To | |
| Move Class org.apache.flink.streaming.tests.artificialstate.eventpayload.ComplexPayload moved to org.apache.flink.streaming.tests.artificialstate.ComplexPayload | From | To | |
| Move Class org.apache.flink.streaming.tests.artificialstate.eventpayload.ArtificialValueStateBuilder moved to org.apache.flink.streaming.tests.artificialstate.builder.ArtificialValueStateBuilder | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute artificialKeyedStateBuilder : List<ArtificialKeyedStateBuilder<IN>> to artificialStateBuilders : List<ArtificialStateBuilder<IN>> in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type stateBuilder : ArtificialKeyedStateBuilder<IN> to stateBuilder : ArtificialStateBuilder<IN> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Change Variable Type stateBuilder : ArtificialKeyedStateBuilder<IN> to stateBuilder : ArtificialStateBuilder<IN> in method public map(value IN) : OUT in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Change Variable Type stateBuilder : ArtificialKeyedStateBuilder<IN> to stateBuilder : ArtificialStateBuilder<IN> in method public ArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, artificialStateBuilders List<ArtificialStateBuilder<IN>>) in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Change Package | 1 | ||
| Change Package org.apache.flink.streaming.tests.artificialstate.eventpayload to org.apache.flink.streaming.tests.artificialstate.builder | From | To | |
| Extract Method | 1 | ||
| Extract Method package createListStateBuilder(inputAndOldStateToNewState JoinFunction<IN,STATE,STATE>, typeSerializer TypeSerializer<STATE>) : ArtificialStateBuilder<IN> extracted from private createArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, inputAndOldStateToNewState JoinFunction<IN,STATE,STATE>, stateSerializers List<TypeSerializer<STATE>>) : ArtificialKeyedStateMapper<IN,OUT> in class org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type artificialKeyedStateBuilder : List<ArtificialKeyedStateBuilder<IN>> to artificialStateBuilders : List<ArtificialStateBuilder<IN>> in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter artificialKeyedStateBuilder : ArtificialKeyedStateBuilder<IN> to artificialStateBuilders : ArtificialStateBuilder<IN> in method public ArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, artificialStateBuilders ArtificialStateBuilder<IN>) in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To | |
| Rename Parameter artificialKeyedStateBuilder : List<ArtificialKeyedStateBuilder<IN>> to artificialStateBuilders : List<ArtificialStateBuilder<IN>> in method public ArtificialKeyedStateMapper(mapFunction MapFunction<IN,OUT>, artificialStateBuilders List<ArtificialStateBuilder<IN>>) in class org.apache.flink.streaming.tests.artificialstate.ArtificialKeyedStateMapper | From | To |