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 | Skype : puneet.ki...@customercentria.com <puneet.ki...@customercentria.com>* *e-mail :puneet.ki...@customercentria.com <puneet.ki...@customercentria.com>*
