MaxCompute用户指南：MapReduce：示例程序：Sleep示例

测试准备

1. 
   准备好测试程序的 Jar 包，假设名字为 mapreduce-examples.jar，本地存放路径为 data\resources。
2. 
   准备好 SleepJob 的测试资源。add jar data\resources\mapreduce-examples.jar -f;

1.   jar -resources mapreduce-examples.jar -classpath data\resources\mapreduce-examples.jar
2.   com.aliyun.odps.mapred.open.example.Sleep 10;
3.   jar -resources mapreduce-examples.jar -classpath data\resources\mapreduce-examples.jar
4.   com.aliyun.odps.mapred.open.example.Sleep 100;

1. package com.aliyun.odps.mapred.open.example;
3. import java.io.IOException;
5. import com.aliyun.odps.mapred.JobClient;
6. import com.aliyun.odps.mapred.MapperBase;
7. import com.aliyun.odps.mapred.conf.JobConf;
9. public class Sleep {
11.   private static final String SLEEP_SECS = "sleep.secs";
13.   public static class MapperClass extends MapperBase {
15.     @Override
16.     public void setup(TaskContext context) throws IOException {
17.       try {
18.         Thread.sleep(context.getJobConf().getInt(SLEEP_SECS, 1) * 1000);
19.       } catch (InterruptedException e) {
20.         throw new RuntimeException(e);
21.       }
22.     }
23.   }
25.   public static void main(String[] args) throws Exception {
26.     if (args.length != 1) {
27.       System.err.println("Usage: Sleep <sleep_secs>");
28.       System.exit(-1);
29.     }
31.     JobConf job = new JobConf();
32.     job.setMapperClass(MapperClass.class);
33.     job.setNumReduceTasks(0);
34.     job.setNumMapTasks(1);
35.     job.set(SLEEP_SECS, args[0]);
37.     JobClient.runJob(job);
38.   }
39. }