yran程式設計有很多地方採用了事件驅動模型,把**簡化,方便理解它。
1.定義乙個事件:
import org.apache.hadoop.yarn.event.abstractevent;
public class taskevent extends abstractevent
public string gettaskid()
}
2.這個事件有2個型別:
public enum taskeventtype
3.定義乙個排程器,測試**也寫進去:
import org.apache.hadoop.conf.configuration;
import org.apache.hadoop.service.compositeservice;
import org.apache.hadoop.service.service;
import org.apache.hadoop.yarn.conf.yarnconfiguration;
import org.apache.hadoop.yarn.event.asyncdispatcher;
import org.apache.hadoop.yarn.event.dispatcher;
import org.apache.hadoop.yarn.event.eventhandler;
private dispatcher dispatcher;
public dispatcher getdispatcher()
super(name);
} @override
protected void serviceinit(configuration arg0) throws exception
private class taskeventdisptacher implements eventhandlerelse if(arg0.gettype() == taskeventtype.t_schedule)
} }
//測試入口
public static void main(string args) throws exception
}
還有些問題,沒有弄明白,先做乙個記錄吧。
hadoop之 yarn (簡單了解)
yarn通過兩個 守護執行緒提供核心服務 resourcemanager,管理集群所有資源的切分以及作業的排程與監控 nodemanager,執行在集群所有節點上,啟動並監控容器的執行狀況,並負責向resourcemanager匯報。在linux上,hadoop是通過cgroup技術實現contai...
Hadoop核心元件之YARN
作業系統級別的排程框架,可以讓各種計算框架執行在上面 yarn 不同計算框架可以共享同乙個hdfs集群上的資料,享受整體的資源排程 on yarn的好處 與其他計算框架共享集群資源,按資源需要分配,進而提高集群資源的利用率 spark mapreduce storm flink 1 resource...
Hadoop學習筆記之YARN
yarn service框架提供了一流的支援和api,可以在yarn中本地化時間執行的服務。簡而言之 in a nutshell 它作為乙個容器編排平台,用於管理yarn上的貨櫃化服務。它支援yarn中的docker容器和傳統的基於程序的容器。該框架的職責包括執行配置解決方案和安裝,生命週期管理 如...