This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from eb58aa1 [hotfix] Fix typo multiple word mistakes
add cebf1bd [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7
sink based on the unified sink (FLIP-143)
No new revisions were added by this update.
Summary of changes:
.../elasticsearch/sink/BulkProcessorConfig.java | 71 +++++
.../elasticsearch/sink/ElasticsearchEmitter.java | 77 +++++
.../elasticsearch/sink/ElasticsearchSink.java | 126 ++++++++
.../sink/ElasticsearchSinkBuilder.java | 246 +++++++++++++++
.../elasticsearch/sink/ElasticsearchWriter.java | 332 +++++++++++++++++++++
.../elasticsearch/sink/FlushBackoffType.java | 37 +++
.../elasticsearch/sink/NetworkClientConfig.java | 53 ++++
.../elasticsearch/sink/RequestIndexer.java | 55 ++++
.../sink/ElasticsearchSinkBuilderTest.java | 85 ++++++
.../sink/ElasticsearchSinkITCase.java | 229 ++++++++++++++
.../sink/ElasticsearchWriterITCase.java | 272 +++++++++++++++++
.../connector/elasticsearch/sink/TestClient.java | 77 +++++
.../connector/elasticsearch/sink/TestEmitter.java | 75 +++++
.../org/apache/flink/util/DockerImageVersions.java | 3 +
pom.xml | 6 +
15 files changed, 1744 insertions(+)
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSink.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilder.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/FlushBackoffType.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/NetworkClientConfig.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/RequestIndexer.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderTest.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkITCase.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriterITCase.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestClient.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestEmitter.java
