Well I thought that in order to do the same with only the datastream api I
would need to use MapPartitionFunction.
Op do 17 feb. 2022 om 10:41 schreef Francesco Guardiani <
france...@ververica.com>:
> Why do you need MapPartitionFunction?
>
> On Wed, Feb 16, 2022 at 7:02 PM HG wrote:
>
>> Tha
Why do you need MapPartitionFunction?
On Wed, Feb 16, 2022 at 7:02 PM HG wrote:
> Thanks
>
> Would the option for datastream be to write a MapPartitionFunction?
>
> Op wo 16 feb. 2022 om 16:35 schreef Francesco Guardiani <
> france...@ververica.com>:
>
>> > Which does not work since it cannot fi
Thanks
Would the option for datastream be to write a MapPartitionFunction?
Op wo 16 feb. 2022 om 16:35 schreef Francesco Guardiani <
france...@ververica.com>:
> > Which does not work since it cannot find lag function :-(
>
> lag and over are not supported at the moment with Table, so you need to
> Which does not work since it cannot find lag function :-(
lag and over are not supported at the moment with Table, so you need to use
SQL for that.
> *Will this obey the watermark strategy of the original Datastream? (see
further below)*
Yes. The code at the end of the mail is correct and shou
Hello all
I need to calculate the difference in time between ordered rows per
transactionId. All events should arrive within the timeframe set by the
out-of-orderness ( a couple of minutes). Events outside this time should be
ignored.
In SQL this would be :
select transactionId , handlingTime ,
