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
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
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