文件名称：PyFlink 有状态流处理 + SkLearn 实现在线机器学习
文件大小：3.87MB
文件格式：ZIP
更新时间：2022-02-21 14:03:30
flink sklearn 机器学习 实时大数据
本实例使用 PyFlink + Scikit-Learn 基于kafka输入的实时手写体数据，在线训练一个手写体识别机器学习模型，以及提供实时的手写体识别服务；并实现对模型训练过程的实时监控。
【文件预览】：
OLLearning
----flink-sql-connector-kafka_2.11-1.14.0.jar(3.53MB)
----data_producer.py(3KB)
----web_server()
--------server.py(3KB)
--------digit.svg(886B)
--------digit.png(1KB)
--------templates()
--------server_requirements.txt(101B)
--------static()
----udf_model.py(5KB)
----img()
--------predict.png(229KB)
--------metrics.png(161KB)
--------train.png(347KB)
----requirements.txt(33B)
----online_learning.py(4KB)
----redis_clear.py(734B)
----__pycache__()
--------udf_model.cpython-38.pyc(3KB)
----docker-compose.yml(1KB)