flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mäki Hanna <Hanna.M...@comptel.com>
Subject FlinkML and DataStream API
Date Wed, 21 Dec 2016 16:24:33 GMT

I'm wondering if there is a way to use FlinkML and make predictions continuously for test
data coming from a DataStream.

I know FlinkML only supports the DataSet API (batch) at the moment, but is there a way to
convert a DataStream into DataSets? I'm thinking of something like

(0. fit model in batch mode)
1. window the DataStream
2. convert the windowed stream to DataSets
3. use the FlinkML methods to make predictions


Disclaimer: This message and any attachments thereto are intended solely for the addressed
recipient(s) and may contain confidential information. If you are not the intended recipient,
please notify the sender by reply e-mail and delete the e-mail (including any attachments
thereto) without producing, distributing or retaining any copies thereof. Any review, dissemination
or other use of, or taking of any action in reliance upon, this information by persons or
entities other than the intended recipient(s) is prohibited. Thank you.

View raw message