大数据之Flink-基本API

Flink基本的API前言Flink使用 DataSet 和 DataStream 代表数据集。DateSet 用于批处理,代表数据是有限的;而 DataStream 用于流数据,代表数据是无界的。数据集中的数据是不可以变的,也就是说不能对其中的元素增加或删除。

PyFlink 教程(三):PyFlink DataStream API – state & timer

简介: 介绍如何在 Python DataStream API 中使用 state & timer 功能。一、背景Flink 1.13 已于近期正式发布,超过 200 名贡献者参与了 Flink 1.13 的开发,提交了超过 1000 个 commits,完成了若干重要功能。

PyFlink 教程(三):PyFlink DataStream API – state & timer

简介: 介绍如何在 Python DataStream API 中使用 state & timer 功能。一、背景Flink 1.13 已于近期正式发布,超过 200 名贡献者参与了 Flink 1.13 的开发,提交了超过 1000 个 commits,完成了若干重要功能。

网站地图