Hi Dongwon, Maybe you can add your use case to the FLIP-107 discussion thread [1] and thereby support the proposal (after checking that it would solve your problem).
It's always helpful to learn about the requirements of users when designing new features. It also helps to prioritize which features to push for. Thank you, Fabian [1] https://lists.apache.org/thread.html/r351dea720788c4f1ca8c5133c34f0f11077a0df54ef4ac8c3e28a6dc%40%3Cdev.flink.apache.org%3E Am Di., 11. Aug. 2020 um 09:42 Uhr schrieb Dongwon Kim < eastcirc...@gmail.com>: > Hi Dawid, > > I'll try your suggestion [2] and wait for [1] to be supported in next > versions. > > Thanks, > > p.s. It's not easy to insert the timestamp into the body because it will > affect other applications. In this regard, I hope [1] is going to be > available soon. > > Dongwon > > > On Tue, Aug 11, 2020 at 4:31 PM Dawid Wysakowicz <dwysakow...@apache.org> > wrote: > >> I'm afraid it is not supported yet. The discussion[1] to support it >> started in the past, but unfortunately it has not concluded yet. >> >> One approach I can think of, how you can work this limitation around is >> to provide your own Format[2]. Unfortunately it is not the most >> straightforward solution. >> >> Best, >> >> Dawid >> >> [1] >> https://cwiki.apache.org/confluence/display/FLINK/FLIP-107%3A+Reading+table+columns+from+different+parts+of+source+records >> >> [2] >> https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sourceSinks.html#encoding--decoding-formats >> On 11/08/2020 09:20, Dongwon Kim wrote: >> >> Hi, >> >> I'm working on a Kafka topic where timestamps are not shown in the >> message body, instead in the message's metadata. >> >> I want to declare a table from the topic with DDL but >> "rowtime_column_name" in the below definition seems to accept only existing >> columns. >> >>> WATERMARK FOR rowtime_column_name AS watermark_strategy_expression. >> >> >> Can I define watermarks in this situation where timestamps are shown only >> in the metadata? >> >> Thanks, >> >> Dongwon >> >>
