# 实时计算 Flink版 #
1
关注
33497内容
|
Windows环境下Flink消费Kafka实现热词统计
前言碎语
昨天博主写了《windows环境下flink入门demo实例》实现了官方提供的最简单的单词计数功能，今天升级下，将数据源从socket流换成生产级的消息队列kafka来完成一样的单词计数功能。
|
Flink UDF自动注册实践
1.注册UDF函数1.1 注册相关方法此处，我们使用的udf函数为标量函数，它继承的是ScalarFunction，该类在我们的使用中，发现它继承自UserDefinedFunction这个类，该处的udf函数由用户自己定义，而函数的注册此处我们自己实现;
函数注册时，使用flink的tableE.
Flink SQL 系列 | 5 个 TableEnvironment 我该用哪个？
本文为 Flink SQL 系列文章的第二篇，前面对 Flink 1.9 Table 新架构及 Planner 的使用进行了详细说明，本文详细讲解 5 个 TableEnvironment 及其适用场景，并介绍 Flink 社区对 TableEnvironment 的未来规划。
|
Flink Broadcast State实用指南
从1.5.0开始，Flink提供了一种新的State类型，称为Broadcast State。在这篇文章中，我们将解释什么是Broadcast State，并展示如何将其应用于评估事件流上的动态模式的应用的示例。
|
Flink常见异常和错误信息小结
Flink的常见异常众多，不可能面面俱到，所以想到哪儿写到哪儿，有漏掉的之后再补充。部署和资源问题(0) JDK版本过低这不是个显式错误，但是JDK版本过低很有可能会导致Flink作业出现各种莫名其妙的问题，因此在生产环境中建议采用JDK 8的较高update（我们使用的是181）。
|
数据中台的存储系统和计算平台枚举
采集&传输层
SqoopHadoop、关系型数据库之间传输数据的工具。传输时，会启动多个MR作业并发的传输数据
DataX阿里巴巴开源的数据同步工具，用来在各种异构数据源之间同步数据。
超强攻略！看完拿 Apache Flink 极客挑战赛全场最佳「MVP」
垃圾图片分类与 Flink TPC-DS 性能优化两大赛题重要知识点及相关工具解析。
免费试用