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/projects/flink/flink-docs-release-1.3/dev/windows.html) and basic transformations (https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/datastream_api.html#datastream-transformations). Regards, Jonas -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Anomaly-Detection-with-Flink-ML-tp14149p14151.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
