flink内部机制和tableAPI

1. 流式 api（DataStream API）

1.1. 样例程序

下面是一个窗口函数计算 ，每  秒计算一次数据，数据从  发送过

来。

 先在  机器上启动 ：

 





"

/**

* Created by wangsenfeng on 2017/11/15.

*/

#$"%&

#'()*! &

++初始化环境

 ,



 getExecutionEnvironment'*

$!'seconds'1**

'-*

++打印数据到控制台

'*

++开启  程序

 '8$!$"8*

;

#

4545677&

<=

;

;

 

package 

import ?

import !!

/**

* Created by wangsenfeng on 2017/11/15.

*/

object $"&

++每 1 秒计算

B'?9**

''?5-**

9:9'2*

$!'seconds'1**

'-*

++打印



++开启

 '8$!$"8*

;

;

1.2. 算子 DataStream Transformations

详情参考：

 一般的 *'+

 特殊的 *'+

1.3. 数据源 Data Sources

以下是一些实现好的数据读取方法，使用 '-.+-"' 访问

 ,"

 3.,"/0读取文本文件，即尊重 3.4,' 规范的文件，逐行并将它们

 ,"/54,'66376"6,"674*0这是前两个方法

内部调用的方法。它根据给定的 54,' 来读取路径中的文件。根据 37

提 供 6 这 源 可 能 定 期 监 测 / 每 间 隔 '0 新 数 据 的 路 径

/,"2"#8219:-(:9;34;<9<=>06 或 过 程 一 旦 数 据 目 前 路 径 和 退 出

/,"2"#8219:-(9;:-0。使用 ,"，用户可以进一步排除正在处理

的文件。

 

 3.'1*'元素可以由分隔符分隔

 :+

 *':+/:+0从 ++ 创建一个数据流。集合中的所有元

据类型

 #?/*'60在给定的时间间隔内生成数字序列。

 :'/自定义0

@*+,.'6*'@AB7

/,"AB:'CD/00*'"

1.4. 数据输出 Data Sinks

 "@3./0!3.9,'将元素作为字符串写入行。字符串是通过调用每个元

素的 "#/0方法获得的

 "@:/0!:9,'将元组写为逗号分隔值文件。行和字段分隔符是可配

置的。每个字段的值都来自对象的 "#/0方法。

 "/0!"3-/0打印标准输出!标准错误流中的每个元素的 "#/0值。可选地，

 "3根据序列化模式将元素写入套接字

 "调用一个自定义沉没函数。," 与其他系统/比如 @B0绑定在一起，

这些系统被实现为沉没功能。

 