Flink ML是一个提供机器学习（ML）API和库的库，可简化机器学习管道的构建。 它为MLlib开发人员提供了一套标准的ML API，以实现ML算法，并提供了ML算法库，这些库可用于为训练和推理工作构建ML管道。
Flink ML是在的保护下开发的。
建设项目
运行mvn clean package命令。
然后，您将找到一个包含应用程序的JAR文件，以及可能作为依赖项添加到该应用程序的任何库： target/-.jar 。
贡献
您可以在了解有关如何进行贡献的更多信息。 对于代码贡献，请仔细阅读“部分，以了解正在进行的社区工作。
执照
该存储库中的代码已获得。
2021-10-12 16:10:49
153KB
1
流计算中的一致性语义定义，以及通常系统怎么支持一致性语义，Flink+Fafka如何实现端到端的一致性语义。Flink会定期地产生checkpoint并且把这些checkpoint写入到一个持久化存储上，比如S3或HDFS。这个写入过程是异步的，这就意味着Flink即使在checkpointing过程中也是不断处理输入数据的。
2021-10-12 10:47:31
16.65MB
1
Flink入门及实战最新内容分享，包含Flink基本原理及应用场景、Flink vs storm vs sparkStreaming、Flink入门案例-wordCount、Flink集群安装部署standalone+yarn、Flink-HA高可用、Flink scala shell代码调试
2021-09-28 16:14:24
1.28MB
1
Flink _ Iceberg 全场景实时数仓的建设实践 - 知乎 (2021_9_15 下午8_42_18).html
2021-09-26 20:04:54
2.39MB
1
这本书绝不仅仅是在讲流式处理，它的真名是"总结过去10年大数据处理发展的历史，Google的经验; 提出新的理论，升维我们的思维模式，降维打击我们的复杂问题；展现目前的行业趋势，预测未来的行业走势…."，这本书几乎影响了我对所有分布式系统的理解。
2021-09-24 10:01:19
31.56MB
1