Hi Maxim,
thanks for the explanation. I think you can set a ValueState and a
ListState for the price and the purchase events, separately. On one hand,
when receiving a purchase event, you first check the price state. If it
exists, you just collect the PurchaseTotal result; otherwise you can
tempor
Hi Xingcan,
On Fri, Nov 3, 2017 at 3:38 AM, Xingcan Cui wrote:
> Hi Maxim,
>
> if I understand correctly, you actually need to JOIN the fast stream with
> the slow stream. Could you please share more details about your problem?
>
Sure I can explain more, with some example of pseudo-code. I have
Hi Flink users,
I'm struggling with some basic concept and would appreciate some help. I
have 2 Input streams, one is fast event stream and one is slow changing
dimension. They have the same key and I use CoProcessFunction to store slow
data in state and enrich fast data from this state. Everythin
