This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 14d32f6 [FLINK-26775][python] WindowOperator#process_element
registers wrong cleanup timer
add 9689dd4 [FLINK-26638][connectors/elasticsearch] Revert Table-API
implementation to SinkFunction-based one
add dab9484 [FLINK-26638][connectors/elasticsearch] Update docs for
Table-API implementation to SinkFunction-based one
No new revisions were added by this update.
Summary of changes:
.../content/docs/connectors/table/elasticsearch.md | 71 ++--
.../table/AbstractTimeIndexGenerator.java | 41 +++
.../table/ElasticsearchConfiguration.java | 169 +++++++++
.../table/ElasticsearchConnectorOptions.java | 171 +++++++++
.../table/ElasticsearchValidationUtils.java | 94 +++++
.../elasticsearch/table/IndexGenerator.java | 39 ++
.../elasticsearch/table/IndexGeneratorBase.java | 52 +++
.../elasticsearch/table/IndexGeneratorFactory.java | 312 ++++++++++++++++
.../elasticsearch/table/KeyExtractor.java | 130 +++++++
.../elasticsearch/table/RequestFactory.java | 54 +++
.../table/RowElasticsearchSinkFunction.java | 140 ++++++++
.../elasticsearch/table/StaticIndexGenerator.java | 35 ++
.../table/IndexGeneratorFactoryTest.java | 282 +++++++++++++++
.../elasticsearch/table/KeyExtractorTest.java | 135 +++++++
.../elasticsearch/table/TestContext.java | 72 ++++
.../table/Elasticsearch6Configuration.java | 79 ++++
.../table/Elasticsearch6DynamicSink.java | 335 +++++++++++++++++
.../table/Elasticsearch6DynamicSinkFactory.java | 186 ++++++++++
.../org.apache.flink.table.factories.Factory | 2 +-
.../Elasticsearch6DynamicSinkFactoryTest.java | 250 +++++++++++++
.../table/Elasticsearch6DynamicSinkITCase.java | 399 +++++++++++++++++++++
.../table/Elasticsearch6DynamicSinkTest.java | 298 +++++++++++++++
.../table/Elasticsearch7Configuration.java | 70 ++++
.../table/Elasticsearch7DynamicSink.java | 335 +++++++++++++++++
.../table/Elasticsearch7DynamicSinkFactory.java | 186 ++++++++++
.../org.apache.flink.table.factories.Factory | 2 +-
.../Elasticsearch7DynamicSinkFactoryTest.java | 234 ++++++++++++
.../table/Elasticsearch7DynamicSinkITCase.java | 376 +++++++++++++++++++
.../table/Elasticsearch7DynamicSinkTest.java | 298 +++++++++++++++
29 files changed, 4801 insertions(+), 46 deletions(-)
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/AbstractTimeIndexGenerator.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConnectorOptions.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchValidationUtils.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGenerator.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorBase.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RequestFactory.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/StaticIndexGenerator.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactoryTest.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractorTest.java
create mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/TestContext.java
create mode 100644
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6Configuration.java
create mode 100644
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java
create mode 100644
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java
create mode 100644
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactoryTest.java
create mode 100644
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
create mode 100644
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkTest.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactoryTest.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
create mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkTest.java
