Thank you again for your detailed response, Fabian. I have this working now! 🎉
I have a follow up question that I'd love your input on, also posted on StackOverflow: https://stackoverflow.com/questions/48591790/apache-flink-best-way-to-architect-many-to-one-join-on-dynamic-table Again, I'm relatively new to Flink, so apologies in advance if this is a simple question. Thanks, Austin On Thu, Feb 1, 2018 at 2:16 AM, Fabian Hueske <fhue...@gmail.com> wrote: > Hi Austin, > > thanks for your questions. > I posted an answer on Stack Overflow. > > Let me know if you have further questions or comments. > > Thanks, Fabian > > > 2018-02-01 6:08 GMT+01:00 Puneet Kinra <puneet.ki...@customercentria.com>: > >> As of now flink doesnt support this feature few days i came across the >> same requirement.. >> >> On Thu, Feb 1, 2018 at 9:55 AM, Austin York <ayork123...@gmail.com> >> wrote: >> >>> I'm relatively new to Flink, so apologies in advance if this is a simple >>> question. >>> >>> I have seen several mentions of an "upsert mode" for dynamic tables >>> based on a unique key in the Flink documentation and on the official Flink >>> blog. However, I do not see any examples / documentation regarding how to >>> enable this mode on a dynamic table. >>> >>> Examples: >>> >>> "When defining a dynamic table on a stream via update mode, we can >>> specify a unique key attribute on the table. In that case, update and >>> delete operations are performed with respect to the key attribute. The >>> update mode is visualized in the following figure." ( >>> https://flink.apache.org/news/2017/04/04/dynamic-tables.html) >>> >>> "A dynamic table that is converted into an upsert stream requires a >>> (possibly composite) unique key." (https://ci.apache.org/project >>> s/flink/flink-docs-release-1.4/dev/table/streaming.html) >>> >>> So my questions are: >>> >>> How do I specify a unique key attribute on a dynamic table in Flink? >>> How do I place a dynamic table in update/upsert/"replace" mode, as >>> opposed to append mode? >>> >>> Posted in StackOverflow as well: https://stackoverflow.co >>> m/questions/48554999/apache-flink-how-to-enable-upsert-mode- >>> for-dynamic-tables >>> >>> Thanks in advance. >>> >>> >> >> >> -- >> *Cheers * >> >> *Puneet Kinra* >> >> *Mobile:+918800167808 <+91%2088001%2067808> | Skype : >> puneet.ki...@customercentria.com <puneet.ki...@customercentria.com>* >> >> *e-mail :puneet.ki...@customercentria.com >> <puneet.ki...@customercentria.com>* >> >> >> >
