主講：侯磊創建動態工作流目錄0102動態工作流初步認識Oozie協調器動態工作流1動態工作流動態工作流通過參數化來節省時間和精力，避免不必要的重復。在這種情況下，參數化是指使用參數而不是硬編碼的值，因此可以在多個地方使用相同的作業。例如，你希望使用Sqoop導入作業將數據從Teradata或Oracle數據庫移動到集群中。你想要執行相同的作業，但在一天或一周內進行輕微的修改。在這種情況下，使用動態工作流可以提高工作效率，并減少對工作流和協調器配置文件的煩瑣修改。動態工作流Oozie通過使用變量、函數甚至表達式來參數化工作流、協調器和捆綁作業。例如，在Oozie工作流中使用廣泛的參數可以使工作流動態化，而不是每次要運行它時重新配Oozie可以使用JSPEL語法，在EL語法中指定的變量、常量、函數和表達式分別被稱為EL變量、EL常量、EL函數和EL表達式。通常，使用EL變量參數化Oozie工作流和協調器。以下是EL變量的一個示例。<name-node>${nameNode}</name-node>動態工作流當提交執行工作流時，Oozie使用在perties文件中為變量指定的值替換變量。Oozie還提供了一組EL常量,例如KB、MB、GB、TB和PB,表示千字節、兆字節等。在Oozie協調器中，Oozie還支持系統變量，如${YEAR}、${MONTH}、${DAY}和${HOUR}。在工作流中，可以使用系統變量來表示Hadoop作業計數器，例如FILE_BYTES_READ、MAP_IN和MAP_OUT。動態工作流工作流可以使用這些作業計數器，如下所示：${hadoop:counters("testMRNode")["FileSystemCounters"]["FILE_BYTES_READ"]}可以在日志文件中打印Hadoop計數器的信息，或者在完成mapper/reducer處理之后，根據mapper和reducer計數器的值進行特定操作。動態工作流Oozie提供了幾個EL功能，用來執行有用的任務。例如:■使用內置函數wf:id()獲取正在執行的工作流的ID?！鍪褂胻imestamp函數以YYYY-MM-DDThh:mm:ss:sZ格式提供當前UTC時間?！鰂s:fileSize(Stringpath)函數是一個HDFSEL函數，返回指定文件的大小(以字節為單位)。初步認識Oozie協調器2初步認識Oozie協調器雖然Oozie工作流包含所有的作業邏輯，但是還缺少一些東西，工作流不提供任何調度功能。Oozie工作流可以幫助我們以指定的順序運行Hadoop應用程序。因此，工作流對于手動運行應用程序很有用。然而，在實踐中,經常需要調度預先創建的Oozie工作流。可以通過Oozie協調器調度Oozie工