From 9b5fce6b1d55205054abbdf274df7af72d1fd263 Mon Sep 17 00:00:00 2001 From: zhangminglei Date: Mon, 18 Dec 2017 15:52:03 +0800 Subject: [PATCH] [FLINK-8199] [elasticsearch] Properly annotate APIs of Elasticsearch connector This closes #5124. --- .../connectors/elasticsearch/ActionRequestFailureHandler.java | 3 +++ .../connectors/elasticsearch/BulkProcessorIndexer.java | 3 +++ .../connectors/elasticsearch/ElasticsearchApiCallBridge.java | 3 +++ .../connectors/elasticsearch/ElasticsearchSinkBase.java | 2 ++ .../connectors/elasticsearch/ElasticsearchSinkFunction.java | 2 ++ .../streaming/connectors/elasticsearch/RequestIndexer.java | 3 +++ .../connectors/elasticsearch/util/ElasticsearchUtils.java | 3 +++ .../connectors/elasticsearch/util/NoOpFailureHandler.java | 2 ++ .../util/RetryRejectedExecutionFailureHandler.java | 2 ++ .../connectors/elasticsearch/Elasticsearch1ApiCallBridge.java | 2 ++ .../streaming/connectors/elasticsearch/ElasticsearchSink.java | 2 ++ .../elasticsearch/IndexRequestBuilderWrapperFunction.java | 2 ++ .../connectors/elasticsearch2/Elasticsearch2ApiCallBridge.java | 2 ++ .../streaming/connectors/elasticsearch2/ElasticsearchSink.java | 2 ++ .../elasticsearch2/OldNewElasticsearchSinkFunctionBridge.java | 2 ++ .../connectors/elasticsearch2/OldNewRequestIndexerBridge.java | 3 +++ .../connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java | 2 ++ .../streaming/connectors/elasticsearch5/ElasticsearchSink.java | 2 ++ 18 files changed, 42 insertions(+) diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ActionRequestFailureHandler.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ActionRequestFailureHandler.java index 3ca1417d807fc..260f80e5860b3 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ActionRequestFailureHandler.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ActionRequestFailureHandler.java @@ -17,6 +17,8 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.PublicEvolving; + import org.elasticsearch.action.ActionRequest; import java.io.Serializable; @@ -56,6 +58,7 @@ * could not be retrieved through the older version Java client APIs (thus, the types will be general {@link Exception}s * and only differ in the failure message). In this case, it is recommended to match on the provided REST status code. */ +@PublicEvolving public interface ActionRequestFailureHandler extends Serializable { /** diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java index 3e290ff245cba..2ebb97c82e213 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java @@ -18,6 +18,8 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.Internal; + import org.elasticsearch.action.ActionRequest; import org.elasticsearch.action.bulk.BulkProcessor; @@ -29,6 +31,7 @@ * Implementation of a {@link RequestIndexer}, using a {@link BulkProcessor}. * {@link ActionRequest ActionRequests} will be buffered before sending a bulk request to the Elasticsearch cluster. */ +@Internal class BulkProcessorIndexer implements RequestIndexer { private final BulkProcessor bulkProcessor; diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java index ce98dfba1b91d..2a7a21659e406 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java @@ -18,6 +18,8 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.Internal; + import org.elasticsearch.action.bulk.BulkItemResponse; import org.elasticsearch.action.bulk.BulkProcessor; import org.elasticsearch.client.Client; @@ -36,6 +38,7 @@ * is allowed, the call bridge will hold reference to the created embedded node. Each instance of the sink will hold * exactly one instance of the call bridge, and state cleanup is performed when the sink is closed. */ +@Internal public interface ElasticsearchApiCallBridge extends Serializable { /** diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java index fe4343ff58379..d3e0e876a3a45 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.Internal; import org.apache.flink.annotation.VisibleForTesting; import org.apache.flink.api.java.utils.ParameterTool; import org.apache.flink.configuration.Configuration; @@ -61,6 +62,7 @@ * * @param Type of the elements handled by this sink */ +@Internal public abstract class ElasticsearchSinkBase extends RichSinkFunction implements CheckpointedFunction { private static final long serialVersionUID = -1007596293618451942L; diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java index 824820408bb96..1b5ce1e06de3b 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java @@ -18,6 +18,7 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.api.common.functions.Function; import org.apache.flink.api.common.functions.RuntimeContext; @@ -56,6 +57,7 @@ * * @param The type of the element handled by this {@code ElasticsearchSinkFunction} */ +@PublicEvolving public interface ElasticsearchSinkFunction extends Serializable, Function { /** diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java index cfa166ef74fc2..2a1b29736b69b 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java @@ -18,12 +18,15 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.PublicEvolving; + import org.elasticsearch.action.ActionRequest; /** * Users add multiple {@link ActionRequest ActionRequests} to a {@link RequestIndexer} to prepare * them for sending to an Elasticsearch cluster. */ +@PublicEvolving public interface RequestIndexer { /** diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/ElasticsearchUtils.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/ElasticsearchUtils.java index 9776c4c9eb6ff..11eede4b70474 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/ElasticsearchUtils.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/ElasticsearchUtils.java @@ -18,6 +18,8 @@ package org.apache.flink.streaming.connectors.elasticsearch.util; +import org.apache.flink.annotation.Internal; + import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.common.transport.TransportAddress; @@ -28,6 +30,7 @@ /** * Suite of utility methods for Elasticsearch. */ +@Internal public class ElasticsearchUtils { /** diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java index dffee20df1915..dfcb9ee8f14bb 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch.util; +import org.apache.flink.annotation.Internal; import org.apache.flink.streaming.connectors.elasticsearch.ActionRequestFailureHandler; import org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer; @@ -25,6 +26,7 @@ /** * An {@link ActionRequestFailureHandler} that simply fails the sink on any failures. */ +@Internal public class NoOpFailureHandler implements ActionRequestFailureHandler { private static final long serialVersionUID = 737941343410827885L; diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/RetryRejectedExecutionFailureHandler.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/RetryRejectedExecutionFailureHandler.java index 370625714e96a..ca710cb75104b 100644 --- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/RetryRejectedExecutionFailureHandler.java +++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/RetryRejectedExecutionFailureHandler.java @@ -18,6 +18,7 @@ package org.apache.flink.streaming.connectors.elasticsearch.util; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.streaming.connectors.elasticsearch.ActionRequestFailureHandler; import org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer; import org.apache.flink.util.ExceptionUtils; @@ -30,6 +31,7 @@ * {@link EsRejectedExecutionException}s (which means that Elasticsearch node queues are currently full), * and fails for all other failures. */ +@PublicEvolving public class RetryRejectedExecutionFailureHandler implements ActionRequestFailureHandler { private static final long serialVersionUID = -7423562912824511906L; diff --git a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/Elasticsearch1ApiCallBridge.java b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/Elasticsearch1ApiCallBridge.java index 5659ee651e8af..2a3c2a0646088 100644 --- a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/Elasticsearch1ApiCallBridge.java +++ b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/Elasticsearch1ApiCallBridge.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.Internal; import org.apache.flink.util.Preconditions; import org.elasticsearch.action.bulk.BulkItemResponse; @@ -40,6 +41,7 @@ /** * Implementation of {@link ElasticsearchApiCallBridge} for Elasticsearch 1.x. */ +@Internal public class Elasticsearch1ApiCallBridge implements ElasticsearchApiCallBridge { private static final long serialVersionUID = -2632363720584123682L; diff --git a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java index bc5ac844c42fa..9dd8209d75011 100644 --- a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java +++ b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSink.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.streaming.connectors.elasticsearch.util.NoOpFailureHandler; import org.elasticsearch.action.ActionRequest; @@ -62,6 +63,7 @@ * * @param Type of the elements handled by this sink */ +@PublicEvolving public class ElasticsearchSink extends ElasticsearchSinkBase { private static final long serialVersionUID = 1L; diff --git a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/IndexRequestBuilderWrapperFunction.java b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/IndexRequestBuilderWrapperFunction.java index 6f1d13845411b..18a723b773ea5 100644 --- a/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/IndexRequestBuilderWrapperFunction.java +++ b/flink-connectors/flink-connector-elasticsearch/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/IndexRequestBuilderWrapperFunction.java @@ -18,12 +18,14 @@ package org.apache.flink.streaming.connectors.elasticsearch; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.functions.RuntimeContext; /** * A dummy {@link ElasticsearchSinkFunction} that wraps a {@link IndexRequestBuilder}. * This serves as a bridge for the usage deprecation of the {@code IndexRequestBuilder} interface. */ +@Internal class IndexRequestBuilderWrapperFunction implements ElasticsearchSinkFunction { private static final long serialVersionUID = 289876038414250101L; diff --git a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/Elasticsearch2ApiCallBridge.java b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/Elasticsearch2ApiCallBridge.java index 66b676c4fca0c..390a4078e2b58 100644 --- a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/Elasticsearch2ApiCallBridge.java +++ b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/Elasticsearch2ApiCallBridge.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch2; +import org.apache.flink.annotation.Internal; import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchApiCallBridge; import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase; import org.apache.flink.streaming.connectors.elasticsearch.util.ElasticsearchUtils; @@ -42,6 +43,7 @@ /** * Implementation of {@link ElasticsearchApiCallBridge} for Elasticsearch 2.x. */ +@Internal public class Elasticsearch2ApiCallBridge implements ElasticsearchApiCallBridge { private static final long serialVersionUID = 2638252694744361079L; diff --git a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java index 0c991a621eef3..a17b4d8543f52 100644 --- a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java +++ b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch2; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.streaming.connectors.elasticsearch.ActionRequestFailureHandler; import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase; import org.apache.flink.streaming.connectors.elasticsearch.util.NoOpFailureHandler; @@ -56,6 +57,7 @@ * * @param Type of the elements handled by this sink */ +@PublicEvolving public class ElasticsearchSink extends ElasticsearchSinkBase { private static final long serialVersionUID = 1L; diff --git a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewElasticsearchSinkFunctionBridge.java b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewElasticsearchSinkFunctionBridge.java index c95fff5d6fd69..0dc5c28cf619b 100644 --- a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewElasticsearchSinkFunctionBridge.java +++ b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewElasticsearchSinkFunctionBridge.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch2; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.functions.RuntimeContext; import org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer; @@ -24,6 +25,7 @@ * A dummy {@link org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkFunction} to bridge * the migration from the deprecated {@link ElasticsearchSinkFunction}. */ +@Internal class OldNewElasticsearchSinkFunctionBridge implements org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkFunction { private static final long serialVersionUID = 2415651895272659448L; diff --git a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewRequestIndexerBridge.java b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewRequestIndexerBridge.java index f42fb44759860..d2e690043c360 100644 --- a/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewRequestIndexerBridge.java +++ b/flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewRequestIndexerBridge.java @@ -17,12 +17,15 @@ package org.apache.flink.streaming.connectors.elasticsearch2; +import org.apache.flink.annotation.Internal; + import org.elasticsearch.action.ActionRequest; /** * A dummy {@link org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer} to bridge * the migration from the deprecated {@link RequestIndexer}. */ +@Internal class OldNewRequestIndexerBridge implements RequestIndexer { private static final long serialVersionUID = 4213982619497149416L; diff --git a/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java b/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java index ffb572df8392c..7c4ba7a97f1dd 100644 --- a/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java +++ b/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch5; +import org.apache.flink.annotation.Internal; import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchApiCallBridge; import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase; import org.apache.flink.streaming.connectors.elasticsearch.util.ElasticsearchUtils; @@ -45,6 +46,7 @@ /** * Implementation of {@link ElasticsearchApiCallBridge} for Elasticsearch 5.x. */ +@Internal public class Elasticsearch5ApiCallBridge implements ElasticsearchApiCallBridge { private static final long serialVersionUID = -5222683870097809633L; diff --git a/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java b/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java index 0f1cc917cab71..3307b2c4f2aae 100644 --- a/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java +++ b/flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java @@ -17,6 +17,7 @@ package org.apache.flink.streaming.connectors.elasticsearch5; +import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.streaming.connectors.elasticsearch.ActionRequestFailureHandler; import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase; import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkFunction; @@ -57,6 +58,7 @@ * * @param Type of the elements handled by this sink */ +@PublicEvolving public class ElasticsearchSink extends ElasticsearchSinkBase { private static final long serialVersionUID = 1L;