Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6391#discussion_r204756208
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java
---
@@ -39,23 +38,25 @@
* exactly one instance of the call bridge, and state cleanup is performed
when the sink is closed.
*/
@Internal
-public interface ElasticsearchApiCallBridge extends Serializable {
+public abstract class ElasticsearchApiCallBridge implements Serializable {
/**
- * Creates an Elasticsearch {@link Client}.
+ * Creates an Elasticsearch client implementing {@link AutoCloseable}.
*
* @param clientConfig The configuration to use when constructing the
client.
* @return The created client.
*/
- Client createClient(Map<String, String> clientConfig);
+ public abstract AutoCloseable createClient(Map<String, String>
clientConfig);
+
+ public abstract BulkProcessor.Builder
createBulkProcessorBuilder(AutoCloseable client, BulkProcessor.Listener
listener);
--- End diff --
No docs here?
---
