flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Basanth Gowda <basanth.go...@gmail.com>
Subject Re: Aggregation by key hierarchy
Date Sun, 13 Aug 2017 21:13:00 GMT
For example - this is a sample model from one of the Apache Apex

I would want to aggregate for different combinations, and different time
buckets. What is the best way to do this in Flink ?


thank you,

On Sun, Aug 13, 2017 at 2:09 PM, Basanth Gowda <basanth.gowda@gmail.com>

> Hi,
> I want to aggregate hits by Country, State, City. I would these as tags in
> my sample data.
> How would I do aggregation at different levels ? Input data would be
> single record
> Should I do flatMap transformation first and create 3 records from 1 input
> record, or is there a better way to do it ?
> thank you,
> basanth

View raw message