[jira] [Created] (FLINK-20210) "RequestFactory" interface in flink elasticsearch connector doesn't support "routing" param

[Shang Yuanchun (Jira)]

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)