1. 程式人生 > >Oozie workflow工作流action間引數傳遞實現

Oozie workflow工作流action間引數傳遞實現

假設workflow裡有兩個action節點,shell和hive,hive需要用到shell節點裡的值,shell指令碼如下

#!/bin/sh
day=`date '+%Y%m%d%H'`
echo "day:$day"

hive節點需傳入day這個引數。需要用到shell節點裡<capture-output/>這個屬性,如下

<action name="shell-118a ">
    <shell xmlns="uri:oozie:shell-action:0.1">
        <job-tracker>${jobTracker}</job-tracker>
        <name-node>${nameNode}</name-node>
        <configuration>
            <property>
                <name>mapred.job.queue.name</name>
                <value>${queueName}</value>
            </property>
        </configuration>
        <exec>${shell}</exec>
        <file>${shell}#${shell}</file>
        <capture-output/>
    </shell>
    <ok to="hive_node "/>
    <error to="fail"/>
</action>
<action name="hive_node">
        <hive xmlns="uri:oozie:hive-action:0.2">
              <job-tracker>${jobTracker}</job-tracker>
              <name-node>${nameNode}</name-node>
              <job-xml>${apps_hdfs_home}/common/conf/hive-site.xml</job-xml>
              <script>${sql}</script>
                <param>day=${wf:actionData('shell-118a')['day']}</param>
        </hive>
        <ok to="end"/>
        <error to="Kill"/>
 </action>

相關推薦

Oozie workflow工作action引數傳遞實現

假設workflow裡有兩個action節點,shell和hive,hive需要用到shell節點裡的值,shell指令碼如下 #!/bin/sh day=`date '+%Y%m%d%H'` e

Hive on oozie以及action引數傳遞

背景: 簡單介紹下 hive action的使用,以及action間是如何進行引數傳遞的,這也是進行多job排程必備的操作~ 叢集環境:CDH 5.13.0 ,其中oozie版本:4.1.0,hive版本:1.1.0 一、Hue配置 Hive ac

vue頁面引數傳遞的方法總結

目錄   方法一:通過路由帶引數進行傳值 方法二:通過設定 Session Storage/local Storage快取的形式進行傳遞 1、 原生用法使用 2、 對Session Storage/local Storage快取進行統一封裝 方法三:父子元件之間的傳

頁面跳轉引數傳遞,新頁面接收引數的方法

function query(name) {     var reg = new RegExp("(^|&)" + name + "=([^&]*)(&|$)", "i");  

Oozie workflow之Hive Action

1、將examples中的hive複製到oozie-apps目錄下,並重命名 /opt/cdh5.14.2/oozie-4.1.0/oozie-apps/hive-select [[email protected] hive-select]# ll total 20 -rw-r--

筆記整理-U3D中不同指令碼引數傳遞

U3D中不同指令碼間引數傳遞1.被呼叫指令碼函式為static型別Static:靜態方法,設定為靜態的方法即使沒有例項化也可以被呼叫。呼叫時直接用指令碼名.函式名()。例項:指令碼b中:    public static void Tell0(stringM)    {   

Gitflow Workflow工作

https://blog.csdn.net/u011904605/article/details/53224420我說的以下流程,sourceTree等工具已經完美的支援了,滑鼠點兩下就完成了。簡直是完美。簡介Feature Branch Workflow是一種非常靈活的開發

Git workflow工作及邊角知識

開篇 Git是個老生長談的問題了,如何在工作協作中使用Git,不同團隊有不同的使用方式,最簡單的可能就單個master分支直接擼,把Git當成svn來使用,這樣用起來簡單,但是缺乏分散式的思想,而且在並行開發過程中,光建立trunk、branch、tag等等的

頁面提交錯誤,頁面引數傳遞java.lang.NumberFormatException: null

   多次出現這樣的錯誤,在點選一個按鈕觸發提交整個頁面的事件時,總是報錯,不止一次出現這樣的錯誤了. 出現這種問題的分析: 1 我們從這個問題的本身來看,java.lang.NumberForma

ABAP WORKFLOW工作建立(一)

SAP的工作流是個很老的內容了 做過幾次工作流的專案,現在有時間稍微寫幾篇部落格 一、TCODE:SWDD 建立一個新的workflow 工作流的流程無非就是兩種,第一:同意。第二:拒絕(或者駁回) 1:同意就是進入下一個節點 2:拒絕就是返回上一個節點,或者是直接返回建立

SharePoint 2013 Nintex Workflow 工作幫助(六)

工作流動作7. Call web service(Integration分組)一個呼叫WebService的操作。自然,配置項中主要是指向一個WebService進行呼叫。關於配置項的說明:URL必填項

Struts2 action引數傳遞方式

2016年6月19日,今天學習Struts2 action的引數傳遞 主要有3種傳輸方式: 1、用action屬性接收 2、用domain model或者dto(data transcation object) 3、實現modelDriven 第一種傳輸方式:直接在acti

workflow工作型別及其區別

在workflow中,工作流分為兩種型別,順序工作流(Sequential)和狀態機工作流(State Machine)。 順序工作流將一系列要執行的步驟以一種預先設計好的流程順序執行。在這種工作流裡,控制流程的是我們很熟悉的如if-else和while迴圈結構。順序工作

PHP頁面引數傳遞的四種方法

第一種: 使用客戶端瀏覽器的cookie。cookie很容易理解,就是一個臨時檔案,可以把它看成一個儲藏室,瀏覽器在瀏覽的過程中記錄一些資訊,就暫時存放在這裡。 在page01中設定一個cookie

WF工作技術內幕 —— 通過Web服務呼叫Workflow工作(基礎例項)

在開發一個企業ERP系統時,其業務流程是開發的關鍵,系統往往會將開發好的業務方案發布為Web服務以供外界呼叫。客戶可以通過伺服器,網際網路等等方式 去呼叫服務,而解決業務上需要及資訊的交換問題。有見及此,微軟在.NET 3.0基礎上釋出了WF,WCF,以及WCS,WPF(為

c#頁面引數傳遞

使用QueryString    使用QuerySting在頁面間傳遞值已經是一種很老的機制了,這種方法的主要優點是實現起來非常簡單,然而它的缺點是傳遞的值是會顯示在瀏覽器的位址列上的(不安全),同時又不能傳遞物件,但是在傳遞的值少而安全性要求不高的情況下, 這個方法還是一

PHP頁面引數傳遞的四種方式

 我們定義page01.php和page02.php兩個php檔案,將page01中的內容想辦法傳遞到page02,然後供我們繼續使用。 第一種:使用客戶端瀏覽器的cookie。cookie很容易理解,就是一個臨時檔案,可以把它看成一個儲藏室,瀏覽器在瀏覽的過程中記錄一些資

mui開發h5+app過程中頁面引數傳遞的總結第一篇

最近在學習mui開發APP,可以說是混合APP的開發。其中涉及到HTML5+的規範,非常值得學習。本人在學習過程中用到了hcoder的h.js也通過hcoder網站的教學視訊學習到很多非常有用的基礎的

activiti 工作任務回退sql實現

今天說一下activiti中任務回退的實現,業務場景:流程中任意節點除了開始節點,每個任務節點都能回退到上級節點,會籤(暫時沒考慮),來個簡單流程圖 1、簡單介紹下activiti開啟流程後表之間的關係,回退任務就是根據表資料的關係,修改表資料完成回退。 ACT_RU_

工作引擎Oozie(一):workflow

觸發 line last ssa pig oozie apt cnblogs 定時任務 1. Oozie簡介 Yahoo開發工作流引擎Oozie(馭象者),用於管理Hadoop任務(支持MapReduce、Spark、Pig、Hive),把這些任務以DAG(有向無環圖)方式