flink abbd6b02d743486f3c0c1336139dd6b3edd20840

abbd6b02d743486f3c0c1336139dd6b3edd20840

Files Diff

Added: 1
Removed: 1
Renamed: 0
Modified: 24

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Method	4
Rename Method public runNullTransportClientTest() : void renamed to public runNullAddressesTest() : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase	From	To
Rename Method public runTransportClientFailsTest() : void renamed to public runInvalidElasticsearchClusterTest() : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase	From	To
Rename Method public runTransportClientTest() : void renamed to public runElasticsearchSinkTest() : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase	From	To
Rename Method public runEmptyTransportClientTest() : void renamed to public runEmptyAddressesTest() : void in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkTestBase	From	To
Change Parameter Type	9
Change Parameter Type elasticsearchSinkFunction : ElasticsearchSinkFunction<T> to elasticsearchSinkFunction : ElasticsearchSinkFunction<Tuple2<Integer,String>> in method protected createElasticsearchSink(bulkFlushMaxActions int, clusterName String, transportAddresses List<InetSocketAddress>, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,TransportClient> in class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSinkITCase	From	To
Change Parameter Type client : AutoCloseable to client : TransportClient in method public createBulkProcessorBuilder(client TransportClient, listener BulkProcessor.Listener) : BulkProcessor.Builder in class org.apache.flink.streaming.connectors.elasticsearch2.Elasticsearch2ApiCallBridge	From	To
Change Parameter Type elasticsearchSinkFunction : ElasticsearchSinkFunction<T> to elasticsearchSinkFunction : ElasticsearchSinkFunction<Tuple2<Integer,String>> in method protected createElasticsearchSink(bulkFlushMaxActions int, clusterName String, transportAddresses List<InetSocketAddress>, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,Client> in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase	From	To
Change Parameter Type client : AutoCloseable to client : TransportClient in method public createBulkProcessorBuilder(client TransportClient, listener BulkProcessor.Listener) : BulkProcessor.Builder in class org.apache.flink.streaming.connectors.elasticsearch5.Elasticsearch5ApiCallBridge	From	To
Change Parameter Type elasticsearchSinkFunction : ElasticsearchSinkFunction<T> to elasticsearchSinkFunction : ElasticsearchSinkFunction<Tuple2<Integer,String>> in method protected createElasticsearchSink(bulkFlushMaxActions int, clusterName String, addresses List<InetSocketAddress>, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,TransportClient> in class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSinkITCase	From	To
Change Parameter Type client : AutoCloseable to client : Client in method public createBulkProcessorBuilder(client Client, listener BulkProcessor.Listener) : BulkProcessor.Builder in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBaseTest.DummyElasticsearchApiCallBridge	From	To
Change Parameter Type client : AutoCloseable to client : RestHighLevelClient in method public createBulkProcessorBuilder(client RestHighLevelClient, listener BulkProcessor.Listener) : BulkProcessor.Builder in class org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge	From	To
Change Parameter Type client : AutoCloseable to client : Client in method public createBulkProcessorBuilder(client Client, listener BulkProcessor.Listener) : BulkProcessor.Builder in class org.apache.flink.streaming.connectors.elasticsearch.Elasticsearch1ApiCallBridge	From	To
Change Parameter Type elasticsearchSinkFunction : ElasticsearchSinkFunction<T> to elasticsearchSinkFunction : ElasticsearchSinkFunction<Tuple2<Integer,String>> in method protected createElasticsearchSinkForEmbeddedNode(bulkFlushMaxActions int, clusterName String, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,Client> in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase	From	To
Change Return Type	9
Change Return Type ElasticsearchSinkBase<T> to ElasticsearchSinkBase<Tuple2<Integer,String>,TransportClient> in method protected createElasticsearchSink(bulkFlushMaxActions int, clusterName String, addresses List<InetSocketAddress>, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,TransportClient> in class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSinkITCase	From	To
Change Return Type ElasticsearchSinkBase<T> to ElasticsearchSinkBase<Tuple2<Integer,String>,TransportClient> in method protected createElasticsearchSink(bulkFlushMaxActions int, clusterName String, transportAddresses List<InetSocketAddress>, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,TransportClient> in class org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSinkITCase	From	To
Change Return Type AutoCloseable to RestHighLevelClient in method public createClient(clientConfig Map<String,String>) : RestHighLevelClient in class org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge	From	To
Change Return Type AutoCloseable to Client in method public createClient(clientConfig Map<String,String>) : Client in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBaseTest.DummyElasticsearchApiCallBridge	From	To
Change Return Type AutoCloseable to TransportClient in method public createClient(clientConfig Map<String,String>) : TransportClient in class org.apache.flink.streaming.connectors.elasticsearch2.Elasticsearch2ApiCallBridge	From	To
Change Return Type ElasticsearchSinkBase<T> to ElasticsearchSinkBase<Tuple2<Integer,String>,Client> in method protected createElasticsearchSink(bulkFlushMaxActions int, clusterName String, transportAddresses List<InetSocketAddress>, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,Client> in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase	From	To
Change Return Type AutoCloseable to TransportClient in method public createClient(clientConfig Map<String,String>) : TransportClient in class org.apache.flink.streaming.connectors.elasticsearch5.Elasticsearch5ApiCallBridge	From	To
Change Return Type AutoCloseable to Client in method public createClient(clientConfig Map<String,String>) : Client in class org.apache.flink.streaming.connectors.elasticsearch.Elasticsearch1ApiCallBridge	From	To
Change Return Type ElasticsearchSinkBase<T> to ElasticsearchSinkBase<Tuple2<Integer,String>,Client> in method protected createElasticsearchSinkForEmbeddedNode(bulkFlushMaxActions int, clusterName String, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,Client> in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkITCase	From	To
Extract Variable	1
Extract Variable builder : RestClientBuilder in method public createClient(clientConfig Map<String,String>) : RestHighLevelClient from class org.apache.flink.streaming.connectors.elasticsearch6.Elasticsearch6ApiCallBridge	From	To
Change Variable Type	1
Change Variable Type client : AutoCloseable to client : Client in method public createClient(clientConfig Map<String,String>) : Client in class org.apache.flink.streaming.connectors.elasticsearch.Elasticsearch1ApiCallBridge	From	To
Change Attribute Type	3
Change Attribute Type callBridge : ElasticsearchApiCallBridge to callBridge : ElasticsearchApiCallBridge<C> in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Change Attribute Type bulkProcessorFlushIntervalMillis : Integer to bulkProcessorFlushIntervalMillis : Long in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Change Attribute Type client : AutoCloseable to client : C in class org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase	From	To
Rename Parameter	2
Rename Parameter userConfig : Map<String,String> to bulkRequestsConfig : Map<String,String> in method private ElasticsearchSink(bulkRequestsConfig Map<String,String>, httpHosts List<HttpHost>, elasticsearchSinkFunction ElasticsearchSinkFunction<T>, failureHandler ActionRequestFailureHandler, restClientFactory RestClientFactory) in class org.apache.flink.streaming.connectors.elasticsearch6.ElasticsearchSink	From	To
Rename Parameter transportAddresses : List<InetSocketAddress> to addresses : List<InetSocketAddress> in method protected createElasticsearchSink(bulkFlushMaxActions int, clusterName String, addresses List<InetSocketAddress>, elasticsearchSinkFunction ElasticsearchSinkFunction<Tuple2<Integer,String>>) : ElasticsearchSinkBase<Tuple2<Integer,String>,TransportClient> in class org.apache.flink.streaming.connectors.elasticsearch5.ElasticsearchSinkITCase	From	To

abbd6b02d743486f3c0c1336139dd6b3edd20840

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: