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

测试准备

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


2. 准备好 SleepJob 的测试资源。add jar data\resources\mapreduce-examples.jar -f;

测试步骤

在 odpscmd 中执行 Sleep，如下所示：

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;

预期结果

作业成功结束后，对比不同 Sleep 时长的运行时间，可以看到效果。

代码示例

1. package com.aliyun.odps.mapred.open.example;


2. 
   
3. import java.io.IOException;


4. 
   
5. import com.aliyun.odps.mapred.JobClient;


6. import com.aliyun.odps.mapred.MapperBase;


7. import com.aliyun.odps.mapred.conf.JobConf;


8. 
   
9. public class Sleep {


10. 
    
11.   private static final String SLEEP_SECS = "sleep.secs";


12. 
    
13.   public static class MapperClass extends MapperBase {


14. 
    
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.   }


24. 
    
25.   public static void main(String[] args) throws Exception {


26.     if (args.length != 1) {


27.       System.err.println("Usage: Sleep ");


28.       System.exit(-1);


29.     }


30. 
    
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]);


36. 
    
37.     JobClient.runJob(job);


38.   }


39. }