flink c4beb3aefa806d1b14ed4d388177935578203bf0

c4beb3aefa806d1b14ed4d388177935578203bf0

Files Diff

Added: 2
Removed: 0
Renamed: 0
Modified: 8

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Variable Type	4
	Change Variable Type source : DataStream<String> to source : DataStream<Tuple2<String,String>> in method public main(args String[]) : void in class org.apache.flink.streaming.tests.Elasticsearch2SinkExample	From	To
	Change Variable Type source : DataStream<String> to source : DataStream<Tuple2<String,String>> in method public main(args String[]) : void in class org.apache.flink.streaming.tests.Elasticsearch1SinkExample	From	To
	Change Variable Type source : DataStream<String> to source : DataStream<Tuple2<String,String>> in method public main(args String[]) : void in class org.apache.flink.streaming.tests.Elasticsearch6SinkExample	From	To
	Change Variable Type source : DataStream<String> to source : DataStream<Tuple2<String,String>> in method public main(args String[]) : void in class org.apache.flink.streaming.tests.Elasticsearch5SinkExample	From	To
	Change Attribute Type	1
	Change Attribute Type requestIndexer : BulkProcessorIndexer to requestIndexer : RequestIndexer in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
	Extract And Move Method	1
	Extract And Move Method public createBulkProcessorIndexer(bulkProcessor BulkProcessor, flushOnCheckpoint boolean, numPendingRequestsRef AtomicLong) : RequestIndexer extracted from public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase & moved to class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchApiCallBridge	From	To