Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
MIME-Version: 1.0
From: Basanth Gowda <basanth.gowda@gmail.com>
Date: Sun, 13 Aug 2017 14:09:14 -0400
Message-ID: <CAGho91h492U9yKyp8bHOa754eCVaQ2uds0U2jNfyGd2n63MaDQ@mail.gmail.com>
Subject: Aggregation by key hierarchy
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary="f403045da182a8b4e00556a6717a"
archived-at: Sun, 13 Aug 2017 18:09:27 -0000

--f403045da182a8b4e00556a6717a
Content-Type: text/plain; charset="UTF-8"

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

--f403045da182a8b4e00556a6717a
Content-Type: text/html; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

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

--f403045da182a8b4e00556a6717a--