MaxCompute用户指南：MapReduce：示例程序：分区表输入示例

本文将为您介绍两个把 Partition 作为输入输出的示例，仅供参考。
示例一：

1.      public static void main(String[] args) throws Exception {
3.      JobConf job = new JobConf();
5.      ...
7.      LinkedHashMap<String, String> input = new LinkedHashMap<String, String>();
8.      input.put("pt", "123456");
9.      InputUtils.addTable(TableInfo.builder().tableName("input_table").partSpec(input).build(), job);
11.      LinkedHashMap<String, String> output = new LinkedHashMap<String, String>();
12.      output.put("ds", "654321");
13.      OutputUtils.addTable(TableInfo.builder().tableName("output_table").partSpec(output).build(), job);
15.      JobClient.runJob(job);
16.     }

1.     package com.aliyun.odps.mapred.open.example;
3.     ...
4.       public static void main(String[] args) throws Exception {
5.         if (args.length != 2) {
6.           System.err.println("Usage: WordCount <in_table> <out_table>");
7.           System.exit(2);
8.         }
10.         JobConf job = new JobConf();
12.         job.setMapperClass(TokenizerMapper.class);
13.         job.setCombinerClass(SumCombiner.class);
14.         job.setReducerClass(SumReducer.class);
16.         job.setMapOutputKeySchema(SchemaUtils.fromString("word:string"));
17.         job.setMapOutputValueSchema(SchemaUtils.fromString("count:bigint"));
20.         Account account = new AliyunAccount("my_access_id", "my_access_key");
21.         Odps odps = new Odps(account);
22.         odps.setEndpoint("odps_endpoint_url");
23.         odps.setDefaultProject("my_project");
25.         Table table = odps.tables().get(tblname);
26.         TableInfoBuilder builder = TableInfo.builder().tableName(tblname);
28.         for (Partition p : table.getPartitions()) {
29.           if (applicable(p)) {
30.             LinkedHashMap<String, String> partSpec = new LinkedHashMap<String, String>();
31.             for (String key : p.getPartitionSpec().keys()) {
32.               partSpec.put(key, p.getPartitionSpec().get(key));
33.             }
34.             InputUtils.addTable(builder.partSpec(partSpec).build(), conf);
35.           }
36.         }
38.         OutputUtils.addTable(TableInfo.builder().tableName(args[1]).build(), job);
40.         JobClient.runJob(job);
41.       }

注意：

• 
  这是一段使用 MaxCompute SDK 和 MapReduce SDK 组合实现 MapReduce 任务读取范围 Partitoin 的示例。
• 
  此段代码不能够编译执行，仅给出了 main 函数的示例。
• 
  示例中 applicable 函数是用户逻辑，用来决定该 Partition 是否符合作为该 MapReduce 作业的输入。