Flink实战(四) - DataSet API编程

2019-07-18 632

1 你将学到

◆ DataSet API开发概述

◆ 计数器

◆ DataSource

◆ 分布式缓存

◆ Transformation

◆ Sink

2 Data Set API 简介

Flink中的DataSet程序是实现数据集转换（例如，过滤，映射，连接，分组）的常规程序.

最初从某些Source源创建数据集（例如，通过读取文件或从本地集合创建）

结果通过sink返回，接收器可以例如将数据写入（分布式）文件或标准输出（例如命令行终端）

Flink程序可以在各种环境中运行，单机运行或嵌入其他程序中

执行可以在本地JVM中执行，也可以在集群机器上执行.

有关Flink API基本概念的介绍，请参阅本系列的上一篇

Flink实战(三) - 编程模型及核心概念

为了创建自己的Flink DataSet程序，鼓励从Flink程序的解剖开始，逐步添加自己的转换!

3

微信关注我们

原文链接：https://yq.aliyun.com/articles/709883

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

正确看待递归函数

什么是递归函数我们都知道基本上的编程语言都支持在一个函数中调用其他的函数。如果这个函数在内部调用它自己，那么我们就称这个函数为递归函数。递归函数的作用可以执行for或while语句相同的任务有些情况可以少写代码，让代码看起来更简练举一个例子，数学中我们有学习过求一个正整数的阶乘。阶乘是基斯顿·卡曼（Christian Kramp，1760～1826）于 1808 年发明的运算符号，是数学术语。一个正整数的阶乘（factorial）是所有小于及等于该数的正整数的积。我们使用PHP语言用两种方法实现阶乘的运算，代码如下： <?php //使用递归的方式 function factorial_1($n){ return $n == 1 ? 1 : $n * factorial($n - 1); } //使用while的方式 function factorial_2($n){ $res = 1; while ($n > 1) { $res = $res * $n--; } return $res; } $n = 5; echo "使用阶乘的方式：" . factoria...

2019-07-19

597

Resource Resource 接口定义 public interface Resource extends InputStreamSource { /** * 返回此资源的 URL 句柄 */ URL getURL() throws IOException; /** * 返回此资源的 URI 句柄 */ URI getURI() throws IOException; /** * 返回此资源的 File 句柄 */ File getFile() throws IOException; /** * 创建此资源的关联资源 */ Resource createRelative(String relativePath) throws IOException; } public interface InputStreamSource { /** * 返回底层资源内容的 InputStream */ InputStream getInputStream() throws IOException; } 内置 Resource 实现者 UrlResource —— 封装 java.net.URL...

2019-07-19

620

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

Flink实战(四) - DataSet API编程

1 你将学到

2 Data Set API 简介

3

正确看待递归函数

Spring 框架文档之核心技术—— Resource

相关文章

发表评论

资源下载

优质分享App

Mario

Rocky Linux

Sublime Text

欢迎您！