You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/03/04 15:10:39 UTC
[flink] branch release-1.10 updated: [FLINK-16280][doc] Fix sample
code errors in the documentation about elasticsearch connector.
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new a255787 [FLINK-16280][doc] Fix sample code errors in the documentation about elasticsearch connector.
a255787 is described below
commit a255787184056c7807f2ccca183902ed8c144a8a
Author: sev7e0 <se...@gmail.com>
AuthorDate: Tue Feb 25 23:17:04 2020 +0800
[FLINK-16280][doc] Fix sample code errors in the documentation about elasticsearch connector.
This closes #11216.
---
docs/dev/connectors/elasticsearch.md | 14 +++++++-------
docs/dev/connectors/elasticsearch.zh.md | 14 +++++++-------
2 files changed, 14 insertions(+), 14 deletions(-)
diff --git a/docs/dev/connectors/elasticsearch.md b/docs/dev/connectors/elasticsearch.md
index 9eae491..111e8fe 100644
--- a/docs/dev/connectors/elasticsearch.md
+++ b/docs/dev/connectors/elasticsearch.md
@@ -273,14 +273,14 @@ val esSinkBuilder = new ElasticsearchSink.Builder[String](
esSinkBuilder.setBulkFlushMaxActions(1)
// provide a RestClientFactory for custom configuration on the internally created REST client
-esSinkBuilder.setRestClientFactory(
- restClientBuilder -> {
- restClientBuilder.setDefaultHeaders(...)
- restClientBuilder.setMaxRetryTimeoutMillis(...)
- restClientBuilder.setPathPrefix(...)
- restClientBuilder.setHttpClientConfigCallback(...)
+esSinkBuilder.setRestClientFactory(new RestClientFactory {
+ override def configureRestClientBuilder(restClientBuilder: RestClientBuilder): Unit = {
+ restClientBuilder.setDefaultHeaders(...)
+ restClientBuilder.setMaxRetryTimeoutMillis(...)
+ restClientBuilder.setPathPrefix(...)
+ restClientBuilder.setHttpClientConfigCallback(...)
}
-)
+})
// finally, build and add the sink to the job's pipeline
input.addSink(esSinkBuilder.build)
diff --git a/docs/dev/connectors/elasticsearch.zh.md b/docs/dev/connectors/elasticsearch.zh.md
index d17952e..90618d6 100644
--- a/docs/dev/connectors/elasticsearch.zh.md
+++ b/docs/dev/connectors/elasticsearch.zh.md
@@ -273,14 +273,14 @@ val esSinkBuilder = new ElasticsearchSink.Builder[String](
esSinkBuilder.setBulkFlushMaxActions(1)
// provide a RestClientFactory for custom configuration on the internally created REST client
-esSinkBuilder.setRestClientFactory(
- restClientBuilder -> {
- restClientBuilder.setDefaultHeaders(...)
- restClientBuilder.setMaxRetryTimeoutMillis(...)
- restClientBuilder.setPathPrefix(...)
- restClientBuilder.setHttpClientConfigCallback(...)
+esSinkBuilder.setRestClientFactory(new RestClientFactory {
+ override def configureRestClientBuilder(restClientBuilder: RestClientBuilder): Unit = {
+ restClientBuilder.setDefaultHeaders(...)
+ restClientBuilder.setMaxRetryTimeoutMillis(...)
+ restClientBuilder.setPathPrefix(...)
+ restClientBuilder.setHttpClientConfigCallback(...)
}
-)
+})
// finally, build and add the sink to the job's pipeline
input.addSink(esSinkBuilder.build)