Oneway Chen created FLINK-20210:
-----------------------------------
Summary: "RequestFactory" interface in flink elasticsearch
connector doesn't support "routing" param
Key: FLINK-20210
URL: https://issues.apache.org/jira/browse/FLINK-20210
Project: Flink
Issue Type: Improvement
Components: Connectors / ElasticSearch
Reporter: Oneway Chen
_org.apache.flink.streaming.connectors.elasticsearch.table.RequestFactory_
This interface doesn't support the "routing" param in its three functions. When
the "routing" param is obligatory, such as Parent-Child Mapping, it will be
quite inconvenient to use the connector directly. So is it possible to extend
this interface?
accordingly, this classes may be changed:
_org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSink_
_org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch7DynamicSink_
_org.apache.flink.streaming.connectors.elasticsearch.table.RowElasticsearchSinkFunction_
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
