Flink实战(五) - DataStream API编程

  1. 云栖社区>
  2. Java技术进阶>
  3. 博客>
  4. 正文

Flink实战(五) - DataStream API编程

javaedge 2019-07-21 00:02:58 浏览645
展开阅读全文

1 概述

Flink中的DataStream程序是实现数据流转换的常规程序(例如,过滤,更新状态,定义窗口,聚合)。

最初从各种源(例如,消息队列,套接字流,文件)创建数据流。

结果通过接收器返回,接收器可以例如将数据写入文件或标准输出(例如命令行终端)。

Flink程序可以在各种环境中运行,独立运行或嵌入其他程序中。 执行可以在本地JVM中执行,也可以在许多计算机的集群上执行。

  • 有关Flink API基本概念的介绍,请参阅
    基本概念

2 入门案例

以下程序是流窗口字数统计应用程序的完整工作示例,它在5秒窗口中对来自Web套接字的单词进行计数。 您可以复制并粘贴代码以在本地运行它。

import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.

网友评论

登录后评论
0/500
评论
javaedge
+ 关注
所属云栖号: Java技术进阶