本篇内容介绍了“什么是Apache Beam”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
民乐ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为创新互联公司的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：18982081108（备注：SSL证书合作）期待与您的合作！
1. 概述
在本教程中，我们将介绍 Apache Beam 并探讨其基本概念。我们将首先演示使用 Apache Beam 的用例和好处，然后介绍基本概念和术语。之后，我们将通过一个简单的例子来说明 Apache Beam 的所有重要方面。
2. Apache Beam是个啥?
Apache Beam(Batch+strEAM)是一个用于批处理和流式数据处理作业的统一编程模型。它提供了一个软件开发工具包，用于定义和构建数据处理管道以及执行这些管道的运行程序。
Apache Beam旨在提供一个可移植的编程层。事实上，Beam管道运行程序将数据处理管道转换为与用户选择的后端兼容的API。目前，支持这些分布式处理后端有：
Apache Apex
Apache Flink
Apache Gearpump (incubating)
Apache Samza
Apache Spark
Google Cloud Dataflow
Hazelcast Jet
3. 为啥选择 Apache Beam
Apache Beam 将批处理和流式数据处理融合在一起，而其他组件通常通过单独的 API 来实现这一点 。因此，很容易将流式处理更改为批处理，反之亦然，例如，随着需求的变化。
Apache Beam 提高了可移植性和灵活性。我们关注的是逻辑，而不是底层的细节。此外，我们可以随时更改数据处理后端。
Apache Beam 可以使用 Java、Python、Go和 Scala等SDK。事实上，团队中的每个人都可以使用他们选择的语言。
4. 基本概念
使用 Apache Beam，我们可以构建工作流图(管道)并执行它们。编程模型中的关键概念是：
PCollection–表示可以是固定批处理或数据流的数据集
PTransform–一种数据处理操作，它接受一个或多个 PCollections 并输出零个或多个 PCollections。
Pipeline–表示 PCollection 和 PTransform 的有向无环图，因此封装了整个数据处理作业。
PipelineRunner–在指定的分布式处理后端上执行管道。
简单地说，PipelineRunner 执行一个管道，管道由 PCollection 和 PTransform 组成。
5. 字数统计示例
现在我们已经学习了 Apache Beam 的基本概念，让我们设计并测试一个单词计数任务。
5.1 建造梁式管道
设计工作流图是每个 Apache Beam 作业的第一步，单词计数任务的步骤定义如下：
1.从原文中读课文。
2.把课文分成单词表。
3.所有单词都小写。
4.删去标点符号。
5.过滤停止语。
6.统计唯一单词数量。
为了实现这一点，我们需要使用 PCollection 和 PTransform 抽象将上述步骤转换为 管道 。
5.2. 依赖
在实现工作流图之前，先添加 Apache Beam的依赖项 到我们的项目：
org.apache.beam beam-sdks-java-core ${beam.version}
Beam管道运行程序依赖于分布式处理后端来执行任务。我们添加 DirectRunner 作为运行时依赖项：
org.apache.beam beam-runners-direct-java ${beam.version} runtime
与其他管道运行程序不同，DirectRunner 不需要任何额外的设置，这对初学者来说是个不错的选择。
5.3. 实现
Apache Beam 使用 Map-Reduce 编程范式 ( 类似 Java Stream)。讲下面内容之前，最好 对 reduce(), filter(), count(), map(), 和 flatMap() 有个基础概念和认识。
首先要做的事情就是 创建管道：
PipelineOptions options = PipelineOptionsFactory.create(); Pipeline p = Pipeline.create(options);
六步单词计数任务：
