As you said, if I select all the time attribute fields from both , which will be the final one？
Benchao Li <libenc...@gmail.com> 于 2020年5月5日周二 17:26写道： > Hi lec, > > You don't need to specify time attribute again like `TUMBLE_ROWTIME`, you > just select the time attribute field > from one of the input, then it will be time attribute automatically. > > lec ssmi <shicheng31...@gmail.com> 于2020年5月5日周二 下午4:42写道： > >> But I have not found there is any syntax to specify time >> attribute field and watermark again with pure sql. >> >> Fabian Hueske <fhue...@gmail.com> 于 2020年5月5日周二 15:47写道： >> >>> Sure, you can write a SQL query with multiple interval joins that >>> preserve event-time attributes and watermarks. >>> There's no need to feed data back to Kafka just to inject it again to >>> assign new watermarks. >>> >>> Am Di., 5. Mai 2020 um 01:45 Uhr schrieb lec ssmi < >>> shicheng31...@gmail.com>: >>> >>>> I mean using pure sql statement to make it . Can it be possible? >>>> >>>> Fabian Hueske <fhue...@gmail.com> 于2020年5月4日周一 下午4:04写道： >>>> >>>>> Hi, >>>>> >>>>> If the interval join emits the time attributes of both its inputs, you >>>>> can use either of them as a time attribute in a following operator because >>>>> the join ensures that the watermark will be aligned with both of them. >>>>> >>>>> Best, Fabian >>>>> >>>>> Am Mo., 4. Mai 2020 um 00:48 Uhr schrieb lec ssmi < >>>>> shicheng31...@gmail.com>: >>>>> >>>>>> Thanks for your replay. >>>>>> But as I known, if the time attribute will be retained and the >>>>>> time attribute field of both streams is selected in the result after >>>>>> joining, who is the final time attribute variable? >>>>>> >>>>>> Benchao Li <libenc...@gmail.com> 于2020年4月30日周四 下午8:25写道： >>>>>> >>>>>>> Hi lec, >>>>>>> >>>>>>> AFAIK, time attribute will be preserved after time interval join. >>>>>>> Could you share your DDL and SQL queries with us? >>>>>>> >>>>>>> lec ssmi <shicheng31...@gmail.com> 于2020年4月30日周四 下午5:48写道： >>>>>>> >>>>>>>> Hi: >>>>>>>> I need to join multiple stream tables using time interval >>>>>>>> join. The problem is that the time attribute will disappear after >>>>>>>> the jon >>>>>>>> , and pure sql cannot declare the time attribute field again . So, to >>>>>>>> make is success, I need to insert the last result of join to kafka >>>>>>>> ,and >>>>>>>> consume it and join it with another stream table in another flink job >>>>>>>> . This seems troublesome. >>>>>>>> Any good idea? >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>> >>>>>>> -- >>>>>>> >>>>>>> Benchao Li >>>>>>> School of Electronics Engineering and Computer Science, Peking >>>>>>> University >>>>>>> Tel:+86-15650713730 >>>>>>> Email: libenc...@gmail.com; libenc...@pku.edu.cn >>>>>>> >>>>>>> > > -- > > Benchao Li > School of Electronics Engineering and Computer Science, Peking University > Tel:+86-15650713730 > Email: libenc...@gmail.com; libenc...@pku.edu.cn > >
