1 概述

F 中的DataStream程序是实现数据流转换的常规程序（例如，过滤，更新状态，定义窗口，聚合）。

最初从各种源（例如，消息队列，套接字流，文件）创建数据流。

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

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

• 有关F API基本概念的介绍，请参阅
  基本概念

2 入门案例

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

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