JingsongLi commented on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1018212419
So I am thinking maybe we can move forward in https://github.com/JingsongLi/flink/pull/18#discussion_r765610007 Add a method to `InitContext`: ``` /** * Returns a metadata subscriber, the {@link SinkWriter} can publish metadata events of type * {@link MetaT} to the subscriber. */ <MetaT> Optional<Consumer<MetaT>> metadataSubscriber(); ``` Sink can decide for itself whether to publish meta information to subscriber. What do you think? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
