GroupBy with count on a joint table only let met write using toRetractStream

Hello, I have a steam of events (coming from a Kinesis Stream) of this form: impressionId | advertid | variationName | eventType | eventTime The end goal is to output back on a Kinesis Stream the count of event of type 'impression' and the count of events of type 'click' however, I need to dro

Re: GroupBy with count on a joint table only let met write using toRetractStream

ertId, impVariationName, impMinute") .select("impAdvertId, impVariationName, clickAdvertId.count as clickCount, impMinute") .where("clickAdvertId != null"); From: Faye Pressly Sent: Friday, August 7, 2020 9:28 PM To: user@flink.apache.o

Re: GroupBy with count on a joint table only let met write using toRetractStream

vertId.count as > clickCount, impMinute") >.where("clickAdvertId != null"); > > -- > *From:* Faye Pressly > *Sent:* Friday, August 7, 2020 9:28 PM > *To:* user@flink.apache.org > *Subject:* GroupBy with count on a joint table o