如何在oozie工作流中创建和设置变量？

Question

如何在Oozie工作流中设置变量？

例如，工作流这里有一个${output}变量，但是它将在哪里设置？

“输出”是一个特殊的词吗?如果是的话，我如何创建自己的变量？

更新:我使用的是Python的hadoop流，而不是Java。

Answer 1

输出不是一个特殊的词。此变量的值将在执行期间使用job.properties文件传递给此工作流。您可以看到一个示例job.properties文件，其中与集群详细信息、环境和许多其他变量相关的所有变量都保留为变量。

Answer 2

您必须使用任何变量名代替OUTPUT.it是一个参数名，only.this参数是用来代替输出文件的。它仅用于存储工作流或协调器示例执行期间的输出值。变量名应该在工作流/协调器示例中定义，如下所示.

<param> OUTPUT=/user/${wf:user()}/${exampleRoot}/output-data/hive</param>

如果要查看该参数文件，请检查<param>标记中指定的路径。

将值存储到该参数，如下所示。

store (alias) into '$OUTPUT';