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