ashajyothi828 commented on issue #2208: URL: https://github.com/apache/iceberg/issues/2208#issuecomment-776110864
@stevenzwu Thanks for your response. We actually tried implementing a custom sink that can determine the table name at runtime, but I faced trouble when trying to generate the table name based on the key. I was not able to get the key in the sink based on which I want to name my table. I see that there's a `getCurrentKey()` function in the KeyedProcessFunction, but that was not available in the sink. Couldn't find anything that can help (with passing the data from the source to sink) in the Sink.Context available. Can you think of anything that can help me with this? ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
