视界

1. 概述

Flink 做为一款流式计算框架，它可用来做批处理，即处理静态的数据集、历史的数据集；也可以用来做流处理，即实时的处理些实时数据流，实时的产生数据流结果，只要数据源源不断的过来，Flink 就能够一直计算下去，这个 Data Sources 就是数据的来源地。

Flink 中你可以使用 StreamExecutionEnvironment.addSource(sourceFunction) 来为你的程序添加数据来源。

Flink 已经提供了若干实现好了的 source functions，当然你也可以通过实现 SourceFunction 来自定义非并行的 source或者实现 ParallelSourceFunction 接口或者扩展 RichParallelSourceFunction 来自定义并行的 source.

2.已有Source

StreamExecutionEnvironment 中可以使用以下几个已实现的 stream sources，

总的来说可以分为下面几大类：

2.1 基于集合

60-100-040-使用-DataSource-介绍相关推荐

你的任务正常人每分钟心跳次数,一般为60~100次/分钟,若超出该范围则需要特别关注任务
你的任务正常人每分钟心跳次数,一般为60~100次/分钟,若超出该范围则需要特别关注任务 (1)将数据中的 heart rate_min与 heart_rate_max 找到,井判断其是否超出了该正常 ...
90天入门UE引擎开发--学习日记(60/100)
教程 Game艺视界 - Ben UE5着色器材质节点快捷键 D键缩小图片节点 A键 Add M键 Multiply D键 Divide 介绍面板节点里第三层是最重要的新建工程 ...
业界第一个真正意义上开源100 Gbps NIC Corundum介绍
来源:内容由本人微信公众号「网络交换FPGA」编译自「FCCM2020」,谢谢.第一次在csdn上发文章. FCCM2020在5月4日开始线上举行,对外免费.我们有幸聆听了其中一个有关100G开源NI ...
简短介绍_中秋节的来历由来简短20字30字中秋节的起源50字100字简介
中秋节是我国的传统佳节.按照史籍的记实,"中秋"一词最早呈此刻<周礼>一书中.小编整理了中秋节来历的简单介绍,既有二三十字的简要版,也有100字左右的介绍,让我们一起了 ...
天逸100装不了linux,天逸100怎么进bios 天逸100怎么重装系统【详细介绍】
联想电脑是国内市场上相对而言更为知名的品牌之一,和国外品牌相比较而言不仅具有性价比方面的优势,并且从用户的实际使用体验看来,更加适合国人的日常使用情况,并且在其他方面的表现也都十分出色,那么今天小编为 ...
C/C++语言100题练习计划 60——励志的数字
名人说:故立志者,为学之心也:为学者,立志之事也.-- 王阳明进度:C/C++语言100题练习计划专栏,目前60/100
SmartClient框架组件介绍
SmartClient框架组件介绍 Jsp页面引入smartClient类库: <SCRIPT SRC=isomorphic/system/modules/ISC_History.js>& ...
java串口发送十六进制数,本文实例为大家分享了Java实现串口通信的具体代码，供大家参考，具体内容如下1.介绍使用Java实现的串口通信程序，支持十六进制数据的发送与接收。源码：...
本文实例为大家分享了Java实现串口通信的具体代码,供大家参考,具体内容如下 1.介绍使用Java实现的串口通信程序,支持十六进制数据的发送与接收. 源码:SerialPortDemo 效果图如下: ...
linux中常用的60个命令及作用详解
Linux 必学的 60 个命令 Linux 提供了大量的命令,利用它可以有效地完成大量的工作,如磁盘操作.文件存取.目录操作.进程管理.文件权限设定等.所以,在 Linux 系统上工作离不开使用系 ...
LInux常用的60个命令，小白必须掌握的命令
login 1.作用 login的作用是登录系统,它的使用权限是所有用户. 2.格式 login [name] [-p][-h 主机名称] 3.主要参数 -p:通知login保存现在的环境参数. -h ...

60-100-040-使用-DataSource-介绍

视界

1. 概述

2.已有Source

2.1 基于集合

60-100-040-使用-DataSource-介绍相关推荐

最新文章

热门文章