Hey Ron,
for accessing keys of a class by their field name (like you did:
.keyBy("accountId",
"agentId", "wideMetricId")), the class needs to be recognized as a POJO by
Flink.
>From the documentation [1] a class is recognized as a POJO when:
-
The class must be public.
-
It must ha
Thanks Stefano -
That helped, but just led to different pain. I think I need to reconsider how I
treat these things. Alas, the subject of a different thread.
Ron
—
Ron Crocker
Principal Engineer & Architect
( ( •)) New Relic
rcroc...@newrelic.com
M: +1 630 363 8835
> On Mar 12, 2016, at 12:11 P
Hi Ron,
not all classes can be used to `keyBy` a stream with. For your case in
particular, it looks like you have to implement Comparable so that Flink
can correctly key your stream based on AggregatableTimesliceImpl.
Take a look at the first slides here for more information on keying:
http://dat
I’m sure this should work, but I’m missing something… I searched the archive
first, but didn’t have much luck finding any insights there.
TL;DR: org.apache.flink.api.common.InvalidProgramException: This type
(GenericType) cannot be
used as key.
I’m just getting started with a 1.0 implementatio
