>> be retained?
>> If not, and there is no sql syntax to declare watermark again, it is
>> equivalent to not being able to do multiple joins in one job.
>>
>> Benchao Li 于2020年5月5日周二 下午9:23写道：
>>
>>> You cannot select more than one time attribute, the planner
; equivalent to not being able to do multiple joins in one job.
>
> Benchao Li 于2020年5月5日周二 下午9:23写道：
>
>> You cannot select more than one time attribute, the planner will give you
>> an Exception if you did that.
>>
>>
>> lec ssmi 于2020年5月5日周二 下午8:34写道：
>>
&g
Even if the time attribute field is retained, will the related watermark
be retained?
If not, and there is no sql syntax to declare watermark again, it is
equivalent to not being able to do multiple joins in one job.
Benchao Li 于2020年5月5日周二 下午9:23写道：
> You cannot select more than one t
You cannot select more than one time attribute, the planner will give you
an Exception if you did that.
lec ssmi 于2020年5月5日周二 下午8:34写道：
> As you said, if I select all the time attribute fields from
> both , which will be the final one？
>
> Benchao Li 于 2020年5月5日周二 17:26写道：
>
As you said, if I select all the time attribute fields from
both , which will be the final one？
Benchao Li 于 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
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 于2020年5月5日周二 下午4:42写道：
> But I have not found there is any syntax to specify time
>
But I have not found there is any syntax to specify time
attribute field and watermark again with pure sql.
Fabian Hueske 于 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
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 :
> I mean using pure sql statement to
I mean using pure sql statement to make it . Can it be possible?
Fabian Hueske 于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
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 :
> Thanks
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 于2020年4月30日周四 下午8:25写道：
> Hi lec,
>
> AFAIK, time attribute will be
Hi lec,
AFAIK, time attribute will be preserved after time interval join.
Could you share your DDL and SQL queries with us?
lec ssmi 于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
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
13 matches
Mail list logo
