flink b5caaef82add4a6f424094d526700c77b011724e

b5caaef82add4a6f424094d526700c77b011724e

Files Diff

Added: 26
Removed: 10
Renamed: 0
Modified: 21

Link to commit

Dependency Action
Added
	org.clapper:grizzled-slf4j_2.10:1.0.2
	org.apache.avro:avro-ipc:1.7.7
	com.data-artisans:flakka-camel_2.10:2.3-custom
	org.joda:joda-convert:1.7
	org.scala-lang:scala-compiler:2.10.4
	commons-beanutils:commons-beanutils-bean-collections:1.8.3
	org.javassist:javassist:3.18.2-GA
	org.scalatest:scalatest_2.10:2.2.2
	com.fasterxml.jackson.core:jackson-databind:2.7.4
	com.fasterxml.jackson.core:jackson-annotations:2.7.4
	com.101tec:zkclient:0.7
	org.apache.commons:commons-compress:1.4.1
	log4j:log4j:1.2.17
	io.netty:netty-all:4.0.27.Final
	joda-time:joda-time:2.5
	org.apache.commons:commons-lang3:3.3.2
	com.google.code.findbugs:jsr305:1.3.9
	org.apache.avro:avro:1.7.7
	org.reflections:reflections:0.9.10
	com.data-artisans:flakka-slf4j_2.10:2.3-custom
	com.github.scopt:scopt_2.10:3.5.0
	org.scala-lang:scala-library:2.10.4
	org.apache.commons:commons-math3:3.5
	com.data-artisans:flakka-testkit_2.10:2.3-custom
	org.apache.httpcomponents:httpcore:4.2.5
	com.data-artisans:flakka-actor_2.10:2.3-custom
	org.apache.httpcomponents:httpclient:4.2.6
	com.fasterxml.jackson.core:jackson-core:2.7.4
	commons-configuration:commons-configuration:1.7
	commons-collections:commons-collections:3.2.2
	org.slf4j:slf4j-log4j12:1.7.7
	commons-cli:commons-cli:1.3.1
	org.slf4j:slf4j-api:1.7.7
	org.scala-lang:scala-reflect:2.10.4
	commons-io:commons-io:2.4
	org.apache.zookeeper:zookeeper:3.4.6
	com.data-artisans:flakka-remote_2.10:2.3-custom
	com.esotericsoftware.kryo:kryo:2.24.0

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	1
Change Parameter Type ctx : SourceContext<Tuple2<Integer,String>> to ctx : SourceFunction.SourceContext<Tuple2<Integer,String>> in method public run(ctx SourceFunction.SourceContext<Tuple2<Integer,String>>) : void in class org.apache.flink.streaming.connectors.elasticsearch.testutils.SourceSinkDataTestKit.TestDataSourceFunction	From	To
Pull Up Attribute	28
Pull Up Attribute private elasticsearchSinkFunction : ElasticsearchSinkFunction<T> from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private elasticsearchSinkFunction : ElasticsearchSinkFunction<T> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_INTERVAL_MS : String from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_INTERVAL_MS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB : String from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public tempFolder : TemporaryFolder from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase to public tempFolder : TemporaryFolder from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS : String from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private client : Client from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private client : Client from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public tempFolder : TemporaryFolder from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSinkITCase to public tempFolder : TemporaryFolder from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase	From	To
Pull Up Attribute private elasticsearchSinkFunction : ElasticsearchSinkFunction<T> from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to private elasticsearchSinkFunction : ElasticsearchSinkFunction<T> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private bulkProcessor : BulkProcessor from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private bulkProcessor : BulkProcessor from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private bulkProcessor : BulkProcessor from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to private bulkProcessor : BulkProcessor from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private failureThrowable : AtomicReference<Throwable> from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private failureThrowable : AtomicReference<Throwable> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private failureThrowable : AtomicReference<Throwable> from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to private failureThrowable : AtomicReference<Throwable> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private LOG : Logger from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to private LOG : Logger from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private client : Client from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to private client : Client from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS : String from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private bulkProcessor : BulkProcessor from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private bulkProcessor : BulkProcessor from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private userConfig : Map<String,String> from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private userConfig : Map<String,String> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_INTERVAL_MS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_INTERVAL_MS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private failureThrowable : AtomicReference<Throwable> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private failureThrowable : AtomicReference<Throwable> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private userConfig : Map<String,String> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private userConfig : Map<String,String> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private LOG : Logger from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private LOG : Logger from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private client : Client from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private client : Client from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_INTERVAL_MS : String from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_INTERVAL_MS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute private LOG : Logger from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private LOG : Logger from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public tempFolder : TemporaryFolder from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSinkITCase to public tempFolder : TemporaryFolder from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Attribute public CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB : String from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to public CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB : String from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Move Attribute	9
Move Attribute private NUM_ELEMENTS : int from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase to private NUM_ELEMENTS : int from class org.apache.flink.streaming.connectors.elasticsearch.testutils.SourceSinkDataTestKit	From	To
Move Attribute private requestIndexer : RequestIndexer from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private requestIndexer : org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer from class org.apache.flink.streaming.connectors.elasticsearch2.OldNewRequestIndexerBridge	From	To
Move Attribute private indexRequestBuilder : IndexRequestBuilder<T> from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private indexRequestBuilder : IndexRequestBuilder<T> from class org.apache.flink.streaming.connectors.elasticsearch.IndexRequestBuilderWrapperFunction	From	To
Move Attribute private transportAddresses : List<InetSocketAddress> from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to private transportAddresses : List<InetSocketAddress> from class org.apache.flink.streaming.connectors.elasticsearch5.Elasticsearch5ApiCallBridge	From	To
Move Attribute private node : Node from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private node : Node from class org.apache.flink.streaming.connectors.elasticsearch.Elasticsearch1ApiCallBridge	From	To
Move Attribute private transportAddresses : List<InetSocketAddress> from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to private transportAddresses : List<InetSocketAddress> from class org.apache.flink.streaming.connectors.elasticsearch2.Elasticsearch2ApiCallBridge	From	To
Move Attribute private node : Node from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to private node : Node from class org.apache.flink.streaming.connectors.elasticsearch.EmbeddedElasticsearchNodeEnvironmentImpl	From	To
Rename Class	3
Rename Class org.apache.flink.streaming.connectors.elasticsearch5.examples.ElasticsearchExample renamed to org.apache.flink.streaming.connectors.elasticsearch5.examples.ElasticsearchSinkExample	From	To
Rename Class org.apache.flink.streaming.connectors.elasticsearch2.examples.ElasticsearchExample renamed to org.apache.flink.streaming.connectors.elasticsearch2.examples.ElasticsearchSinkExample	From	To
Rename Class org.apache.flink.streaming.connectors.elasticsearch.examples.ElasticsearchExample renamed to org.apache.flink.streaming.connectors.elasticsearch.examples.ElasticsearchSinkExample	From	To
Move And Rename Class	1
Move And Rename Class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase.TestSourceFunction moved and renamed to org.apache.flink.streaming.connectors.elasticsearch.testutils.SourceSinkDataTestKit.TestDataSourceFunction	From	To
Move Class	5
Move Class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSinkFunction moved to org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkFunction	From	To
Move Class org.apache.flink.streaming.connectors.elasticsearch5.RequestIndexer moved to org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer	From	To
Move Class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSinkITCase.TestElasticsearchSinkFunction moved to org.apache.flink.streaming.connectors.elasticsearch.testutils.SourceSinkDataTestKit.TestElasticsearchSinkFunction	From	To
Move Class org.apache.flink.streaming.connectors.elasticsearch2.BulkProcessorIndexer moved to org.apache.flink.streaming.connectors.elasticsearch.BulkProcessorIndexer	From	To
Move Class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSinkITCase.PluginNode moved to org.apache.flink.streaming.connectors.elasticsearch.EmbeddedElasticsearchNodeEnvironmentImpl.PluginNode	From	To
Merge Variable	1
Merge Variable [esConfig : Map<String,String>, sinkConfig : Map<String,String>] to userConfig : Map<String,String> in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.elasticsearch5.examples.ElasticsearchSinkExample	From	To
Change Variable Type	3
Change Variable Type source : SingleOutputStreamOperator<String> to source : DataStream<String> in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.elasticsearch5.examples.ElasticsearchSinkExample	From	To
Change Variable Type source : SingleOutputStreamOperator<String> to source : DataStream<String> in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.elasticsearch2.examples.ElasticsearchSinkExample	From	To
Change Variable Type indexer : RequestIndexer to indexer : org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.elasticsearch2.examples.ElasticsearchSinkExample	From	To
Split Variable	1
Split Variable config : Map<String,String> to [userConfig : Map<String,String>, index : String] in method public testEmbeddedNode() : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase	From	To
Extract Method	4
Extract Method private createIndexRequest(element String) : IndexRequest extracted from public main(args String[]) : void in class org.apache.flink.streaming.connectors.elasticsearch.examples.ElasticsearchSinkExample	From	To
Extract Method private checkErrorAndRethrow() : void extracted from public close() : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Rename Method	1
Rename Method public testNodeClient() : void renamed to public testEmbeddedNode() : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase	From	To
Pull Up Method	9
Pull Up Method public open(configuration Configuration) : void from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to public open(parameters Configuration) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public close() : void from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to public close() : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public close() : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to public close() : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public open(configuration Configuration) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to public open(parameters Configuration) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public invoke(element T) : void from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to public invoke(value T) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public close() : void from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to public close() : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public invoke(element T) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink to public invoke(value T) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public invoke(element T) : void from class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink to public invoke(value T) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Pull Up Method public open(configuration Configuration) : void from class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink to public open(parameters Configuration) : void from class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Rename Variable	2
Rename Variable config : Map<String,String> to userConfig : Map<String,String> in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.elasticsearch.examples.ElasticsearchSinkExample	From	To
Rename Variable config : Map<String,String> to userConfig : Map<String,String> in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.elasticsearch2.examples.ElasticsearchSinkExample	From	To
Extract Superclass	2
Extract Superclass org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase from classes [org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase, org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSinkITCase, org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSinkITCase]	From	To
Extract Superclass org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase from classes [org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink, org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink, org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSink]	From	To
Rename Parameter	7
Rename Parameter element : T to value : T in method public invoke(value T) : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Rename Parameter transportNodes : List<TransportAddress> to transportAddresses : List<TransportAddress> in method public ElasticsearchSink(userConfig Map<String,String>, transportAddresses List<TransportAddress>, indexRequestBuilder IndexRequestBuilder<T>) in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSink	From	To
Rename Parameter configuration : Configuration to parameters : Configuration in method public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To

b5caaef82add4a6f424094d526700c77b011724e

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: