如何编写自己的Hadoop调度器
步骤1 编写JobInProgressListener
步骤2 编写调度器类,继承抽象类TaskScheduler
步骤3 配置并启用Hadoop调度器
//编写自己的 JobInProgressListener 抽象类
abstract class JobInProgressListener {
public abstract void jobAdded(JobInProgress job) throws IOException;
public abstract void jobRemoved(JobInProgress job);
public abstract void jobUpdated(JobChangeEvent event);
}
1