运行 HDInsight 随附的 MapReduce 示例

项目
04/08/2024

Linux cluster

了解如何在 HDInsight 上运行 Apache Hadoop 随附的 MapReduce 示例。

先决条件

HDInsight 中的 Apache Hadoop 群集。请参阅 Linux 上的 HDInsight 入门。
SSH 客户端。有关详细信息，请参阅使用 SSH 连接到 HDInsight (Apache Hadoop)。

MapReduce 示例

示例位于 /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar 处的 HDInsight 群集上。这些示例的源代码包含在 /usr/hdp/current/hadoop-client/src/hadoop-mapreduce-project/hadoop-mapreduce-examples 处的 HDInsight 群集上。

下面的示例都包含在该存档文件中：

示例	说明
aggregatewordcount	计算输入文件中的单词数。
aggregatewordhist	计算输入文件中单词的直方图。
`bbp`	使用 Bailey-Borwein-Plouffe 来计算 Pi 的精确位数。
dbcount	计算存储在数据库中的 pageview 日志数。
distbbp	使用 BBP 类型的公式来计算 Pi 的精确位数。
grep	计算输入中某个正则表达式的匹配数。
join	将经过排序且等分的数据集联接起来。
multifilewc	计算多个文件中的单词数。
pentomino	平铺排列程序，用于查找五格拼板问题的解决方案。
pi	使用拟蒙特卡罗法估算 Pi 值。
randomtextwriter	为每个节点写入 10 GB 的随机文本数据。
`randomwriter`	为每个节点写入 10 GB 的随机数据。
`secondarysort`	定义化简阶段的次级排序。
sort	对随机写入器所写入的数据进行排序。
sudoku	数独解算器。
teragen	为 terasort 生成数据。
terasort	运行 terasort。
teravalidate	检查 terasort 的结果。
wordcount	计算输入文件中的单词数。
`wordmean`	计算输入文件中单词的平均长度。
`wordmedian`	计算输入文件中单词的中值长度。
wordstandarddeviation	计算输入文件中单词长度的标准差。

运行 wordcount 示例

使用 SSH 连接到 HDInsight。将 CLUSTER 替换为群集的名称，然后输入以下命令：
```
ssh sshuser@CLUSTER-ssh.azurehdinsight.cn
```
在 SSH 会话中，使用以下命令来列出示例：
```
yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar
```
此命令将生成本文档前一节的示例列表。
使用以下命令来获取有关特定示例的帮助。在本例中为 wordcount 示例：
```
yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar wordcount
```
会收到以下消息：
```
Usage: wordcount <in> [<in>...] <out>
```
此消息表示可以为源文档提供多个输入路径。最后的路径是存储输出（源文档中的单词计数）的位置。
使用以下语句来计算《达芬奇笔记》（已作为示例数据提供给群集）中所有单词的数目：
```
yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar wordcount /example/data/gutenberg/davinci.txt /example/data/davinciwordcount
```
将从 /example/data/gutenberg/davinci.txt 读取此作业的输入。此示例的输出存储于 /example/data/davinciwordcount 中。两个路径皆位于群集的默认存储，而不是本地文件系统。

注意

如字数统计示例帮助中所述，还可以指定多个输入文件。例如，hadoop jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar wordcount /example/data/gutenberg/davinci.txt /example/data/gutenberg/ulysses.txt /example/data/twowordcount 会计算 davinci.txt 和 ulysses.txt 中单词的数目。
作业完成后，使用以下命令查看输出：
```
hdfs dfs -cat /example/data/davinciwordcount/*
```
此命令将连接通过该作业生成的所有输出文件。它将输出显示到控制台。输出与以下文本类似：
```
zum     1
zur     1
zwanzig 1
zweite  1
```
每一行表示一个单词，并显示它在输入数据中的出现次数。

数独示例

数独是由九个 3x3 网格组成的逻辑拼图。网格中的某些单元格包含数字，其他单元格为空白，游戏目的是找出空白单元格。上一链接包含更多有关此拼图的信息，不过此示例的目的是找出空白单元格。因此，我们的输入应该是采用以下格式的文件：

九行加九列
每一列可能包含数字或 ?（表示空白单元格）
用空格来分隔单元格

可以通过特定方式来构造数独游戏；每一列或行的数字不能重复。存在一个正确构造的 HDInsight 群集示例。它位于 /usr/hdp/*/hadoop/src/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/dancing/puzzle1.dta，且包含以下文本：

8 5 ? 3 9 ? ? ? ?
? ? 2 ? ? ? ? ? ?
? ? 6 ? 1 ? ? ? 2
? ? 4 ? ? 3 ? 5 9
? ? 8 9 ? 1 4 ? ?
3 2 ? 4 ? ? 8 ? ?
9 ? ? ? 8 ? 5 ? ?
? ? ? ? ? ? 2 ? ?
? ? ? ? 4 5 ? 7 8

若要通过数独示例来运行此示例问题，请使用如下命令：

yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar sudoku /usr/hdp/*/hadoop/src/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/dancing/puzzle1.dta

显示结果类似以下文本：

8 5 1 3 9 2 6 4 7
4 3 2 6 7 8 1 9 5
7 9 6 5 1 4 3 8 2
6 1 4 8 2 3 7 5 9
5 7 8 9 6 1 4 2 3
3 2 9 4 5 7 8 1 6
9 4 7 2 8 6 5 3 1
1 8 5 7 3 9 2 6 4
2 6 3 1 4 5 9 7 8

Pi (π) 示例

该示例使用统计学方法（拟蒙特卡罗法）来估算 pi 值。点随机置于单位正方形中。正方形还包含一个圆圈。点位于圆圈中的概率等于圆圈面积 pi/4。可以根据 4R 的值估算 pi 的值。 R 是落入圆圈内的点数与正方形内总点数的比率。所使用的取样点越多，估算值越准确。

请使用以下命令运行此示例。该命令使用 16 个映射（每个映射 10,000,000 个示例）来估算 pi 值：

yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar pi 16 10000000

此命令返回的值类似于 3.14159155000000000000。例如，pi 采用前 10 位小数时为 3.1415926535。

10-GB GraySort 示例

GraySort 是一种基准排序。其指标为在给大量数据（通常至少 100 TB）排序时达到的排序速率（TB/分钟）。

此示例使用适中的 10 GB 数据，这样它运行时能相对快一点。它使用由 Owen O'Malley 和 Arun Murthy 开发的 MapReduce 应用程序。这些应用程序以 0.578 TB/分钟（100 TB 用时 173 分钟）的速率赢得了 2009 年年度常用（“daytona”）TB 级排序基准。有关这一排序基准和其他排序基准的详细信息，请参阅排序基准站点。

本示例使用三组 MapReduce 程序：

TeraGen：一种 MapReduce 程序，用于生成要进行排序的数据行
TeraSort：以输入数据为例，使用 MapReduce 将数据排序到总序中

TeraSort 是一种标准 MapReduce 排序，但自定义的分区程序除外。此分区程序使用 N-1 个抽样键（用于定义每次化简的键范围）的已排序列表。具体说来，sample[i-1] <= key < sample[i] 之类的所有键都将会发送到化简变量 i。此分区程序可确保化简变量 i 的输出全都小于化简变量 i+1 的输出。
TeraValidate：一个 MapReduce 程序，用于验证输出是否已全局排序

它在输出目录中对于每个文件创建一个映射，每个映射都确保每个键均小于或等于前一个键。此映射函数生成每个文件第一个和最后一个键的记录。化简函数确保文件 i 的第一个键大于文件 i-1 的最后一个键。任何问题都会报告为包含故障键的化简阶段的输出结果。

使用以下步骤来生成数据，排序，并对输出进行验证：

生成 10 GB 数据，这些数据被存储到 HDInsight 群集在 /example/data/10GB-sort-input 处的默认存储：
```
yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar teragen -Dmapred.map.tasks=50 100000000 /example/data/10GB-sort-input
```
-Dmapred.map.tasks 告诉 Hadoop 多少个映射任务用于此作业。最后两个参数指示作业创建 10 GB 数据并将其存储在 /example/data/10GB-sort-input 处。

使用以下命令对数据排序：

yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar terasort -Dmapred.map.tasks=50 -Dmapred.reduce.tasks=25 /example/data/10GB-sort-input /example/data/10GB-sort-output

-Dmapred.reduce.tasks 告诉 Hadoop 多少个化简任务用于此作业。最后两个参数只是数据的输入和输出位置。

使用以下方法来验证排序所生成的数据：

yarn jar /usr/hdp/current/hadoop-mapreduce-client/hadoop-mapreduce-examples.jar teravalidate -Dmapred.map.tasks=50 -Dmapred.reduce.tasks=25 /example/data/10GB-sort-output /example/data/10GB-sort-validate

后续步骤

在本文中，学习了如何运行基于 Linux 的 HDInsight 群集附带的示例。有关 Pig、Hive 和 MapReduce 如何与 HDInsight 配合使用的教程，请参阅以下主题：

通过