`
文章列表
控制节点包括start、end、kill、decision、fork、join。其中start、end、kill代表了工作流的起始及工作流执行逻辑(路径),如decision、fork、join 节点名称必需复合 [a-zA-Z][\-_a-zA-Z0-0]* ,最大20个字符; start控制节点 此节点是工作流任务的入口点,工作流定义必须有一个start节点 语法: <workflow-app name="[WF-DEF-NAME]" xmlns="uri:oozie:workflow:0.1">   ...   <sta ...

oozie-工作流定义

工作流定义由控制节点及动作节点组成,控制节点包括start、end、decision、fork、join、kill,动作节点包括map-reduce、pig、hive等 工作流定义语言是基于XML的,叫hPDL(Hadoop Process Definition Language) Oozie 不支持循环定义工作流,在部署阶段会检测循环定义动作,如检测到,Oozie不会提交此工作流;
一个工作流应用主要是靠DAG来协调actions,如M/R、Pig、子工作流等; 流程控制,是通过decision、fork 和 join来控制的,循环工作流目前Oozie还不支持; Actions 和 decisions 可以通过任务的属性文件来传递参数,如actions 输入/输出.通过${VARS}来访问属性文件定义的参数; 一个工作流应用是一个ZIP格式的文件,ZIP文件中包含了工作流定义(XML 文件)、Jars、等应用要用到的资源; 要运行工作流任务,通过oozie命令来提交任务; 监控工作流运行情况,可以通过WEB Console、命令行工具、及WebService AP ...

oozie 工作流概念

定义: Action: 一个计算任务(如M/R,Pig,Hive,Pojo java,做为工作流的一个"action node"; Workflow: Action的集合,控制依赖通过DAG来定义。控制依赖是指一个任务的运行依赖于另一个任务的结束; Workflow Definition:使工作流可运行; Workflow Definition Language: 工作流定义语言hPDL(Hadoop Process Definition Language); Workflow Job: 一个工作流定义的实例; Workflow Engine: 执行工作流任务的系 ...

oozie 介绍

Oozie 是一个管理hadoop任务的工作流/协调系统 Oozie工作流是基于DAGs Oozie协调系统通过时间及数据可用来激活任务调度 Oozie 支持的任务包括M/R job, Streaming Job , Pig, Hive, Distcp , pojo java Oozie 是一个可以扩展的系统,你可以写插件
Transform List(1, 2, 3, 4, 5) map { _ * 2 } Reduce List(1, 2, 3, 4, 5) reduceLeft { _ * _ } The first _ represents the argument that is accumulating the value of the reduction, and the second _ represents the current element of the list. Function Literals and Closures var factor = 3 val multipl ...
函数式编程,其实就是我们常用的method,procedure,function。

Akka 参考-01

    博客分类:
  • akka
转发:http://www.oschina.net/p/akka

Actor 参考-01

    博客分类:
  • akka
转发:http://www.cnblogs.com/JeffreyZhao/archive/2009/05/11/a-simple-actor-model-implementation.html
Global site tag (gtag.js) - Google Analytics