This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 0a672e365 [INLONG-6962][Sort] Add read phase metric and table level
metric for MySQL-CDC (#6966)
add 639e5dfe4 [INLONG-6908][Sort] Support all rowkinds for metric
computing for es connector (#6958)
No new revisions were added by this update.
Summary of changes:
.../sort/elasticsearch6/ElasticsearchSink.java | 19 ++++--
.../table/Elasticsearch6DynamicSink.java | 12 +---
.../sort/elasticsearch7/ElasticsearchSink.java | 18 +++++-
.../table/Elasticsearch7DynamicSink.java | 3 +-
.../sort/elasticsearch/ElasticsearchSinkBase.java | 57 +++++++++++++++---
.../elasticsearch/ElasticsearchSinkFunction.java | 13 ++--
.../table/RowElasticsearchSinkFunction.java | 70 +++-------------------
.../sort/parser/ElasticsearchSqlParseTest.java | 7 +--
8 files changed, 97 insertions(+), 102 deletions(-)
