Flink 是一个流处理框架，支持流处理和批处理，特点是流处理有限，可容错，可扩展，高吞吐，低延迟。

Flink 的算子函数和spark的大致一样，但是由于其是流处理的模式，所有还要有需要加强理解的地方

在大数据时代，金融科技公司通常借助消费数据来综合评估用户的信用和还款能力。这个过程中，某些中介机构会搜集大量的号并进行“养号”工作，即在一年周期里让这些号形成正常的消费、通讯记录，目的是将这些号“培养”得非常...

老板都是复制整个工厂的整体把控的， 一般不亲自动手，只需要管好 工厂的车间组长 就可以了。 JobManager 则是负责整个集群的资源管理与任务管理， 当然他不需要亲自管理，一般都是交给 TaskManager。...

使用Python进行数据分析是一件专业领域的事情，所以要想强化数据分析的技能，需要大家不断练习。同时，我们也需要向有经验的数据分析师学习他们的专业技巧。这篇文章我们介绍来自数据分析大师分享的七个可以提升分析能力的...

1.UDF: 自定义标量函数(User Defined Scalar Function)。一行输入一行输出。2.UDAF: 自定义聚合函数。多行输入一行输出。3.UDTF: 自定义表函数。一行输入多行输出或一列输入多列输出。...

Apache Flink® - Stateful Computations over Data Streams

许多的数据科学家，分析师和 BI 用户依赖交互式 SQL 查询分析数据。Flink SQL 是 Flink 的核心模块之一。作为一个分布式的 SQL 查询引擎。Flink SQL 提供了各种异构数据源的联合查询。开发者可以很方便地在一个程序中...

这里创建了一个 Task 对象并启动，我们来看一下 Task 启动的时候都做了什么

由Apache Flink提供支持的Cloudera Streaming Analytics的1.2.0.0版本提供了广泛的新功能 ，包括通过Apache Atlas 支持血缘和元数据跟踪，支持连接到Apache Kudu 以及期待已久的FlinkSQL API 的第一次迭代。...