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