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>* > > >
