MaxCompute快速入门：编写MapReduce

本文将为您介绍安装好 MaxCompute 客户端后，如何快速运行 MapReduce WordCount 示例程序。如果您使用 Maven，可以从 Maven 库 中搜索 odps-sdk-mapred 获取不同版本的 Java SDK。相关配置信息如下所示：

1. <dependency>
2.     <groupId>com.aliyun.odps</groupId>
3.     <artifactId>odps-sdk-mapred</artifactId>
4.     <version>0.26.2-public</version>
5. </dependency>

注意：

• 
  编译、运行 MapReduce 需要安装 JDK1.6 版本。
• 
  MaxCompute 客户端的快速部署请参见 快速开始。更多关于 MaxCompute 客户端的使用，请参见 MaxCompute 客户端参考手册。

1. 
   创建输入和输出表，如下所示：CREATE TABLE wc_in (key STRING, value STRING);
2. CREATE TABLE wc_out (key STRING, cnt BIGINT);
3. -- 创建输入、输出表

• 
  使用 Tunnel 命令上传数据。
  1. tunnel upload kv.txt wc_in
  2. -- 上传示例数据
  
  kv.txt 文件中的数据如下：
  1. 238,val_238
  2. 186,val_86
  3. 186,val_86
• 
  您也可以用 SQL 语句直接插入数据，示例如下：
  1. insert into table wc_in select '238',' val_238' from (select count(*) from wc_in) a;

1. add jar word-count-1.0.jar;

1. jar -resources word-count-1.0.jar -classpath /home/resources/word-count-1.0.jar com.taobao.jingfan.WordCount wc_in wc_out;

1. select * from wc_out;

注意：
如果您在 Java 程序中使用了任何资源，请务必将此资源加入 -resources 参数。Jar 命令的详细介绍请参见 作业提交。