flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aitozi <gjying1...@gmail.com>
Subject Streaming
Date Wed, 27 Jun 2018 09:12:02 GMT
Hi, community

I am using flink to deal with some situation.

1. "distinct count" to calculate the uv/pv.
2.  calculate the topN of the past 1 hour or 1 day time.

Are these all realized by window? Or is there a best practice on doing this?

3. And when deal with the distinct, if there is no need to do the keyBy
previous, how does the window deal with this.


Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

View raw message