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

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Connectors / ElasticSearch
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Oneway Chen
• Created: 18/Nov/20 08:53
• Updated: 09/Nov/21 10:43

Description

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