Great information!
Thanks Jonas!
-- Original message--
From: Jonas Gröger
Date: Fri, Jul 7, 2017 4:12 PM
To: user@flink.apache.org;
Cc:
Subject:Re: Anomaly Detection with Flink-ML
Hello Jeremy,
it looks like what you are looking for is map (1 in, 1 out) / flatmap (1 in,
0-n out) for pr
Hello Jeremy,
it looks like what you are looking for is map (1 in, 1 out) / flatmap (1 in,
0-n out) for preprocessing on a single element basis as well as windows for
looking at related MetricDefinition elements calculating some result.
I suggest you look into Windows
(https://ci.apache.org/proje