A couple of question for Stateful Functions

2020-09-01 Thread danp
Hi, Nice to see the progress of Stateful functions. I have a few questions that I hope you can reply to. My first question is regarding the newly implemented StatefulFunctionDataStreamBuilder. Is there anything to pay attention to if one first union a couple of streams and performs a sort via a

SQL Function with more than one parameter IN

2021-01-07 Thread danp
Hi everyone, I just posted to the Apache BEAM mailing list to find out if there is good syntax for my usecase. I've been following Flink for he last couple of yours so that why I'm emailing more here the same email to you aswell. I've been reading thru both the Beam and the Flink website about