Danny Cranmer created FLINK-29938:
-------------------------------------
Summary: Add open() Method to AsyncSink ElementConverter
Key: FLINK-29938
URL: https://issues.apache.org/jira/browse/FLINK-29938
Project: Flink
Issue Type: Improvement
Components: Connectors / Common
Reporter: Danny Cranmer
The {{ElementConverter}} is used to convert records to objects that a Sink can
deliver to a destination. In some sink implementations, the
{{ElementConverter}} needs to be serialized and sent to TM, DynamoDB is a good
example. For DynamoDB we need to lazily instantiate some objects, and an
`open()` method would provide a clean hook for this.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
