9

単純なワークフローをoozieに変換しようとしています。私はoozieの例を調べてみましたが、少し圧倒されます。事実上、クエリを実行して結果をテキストファイルに出力したいと思います。

hive -e 'select * from tables' > output.txt

それを1時間ごとに実行するためにoozieに変換するにはどうすればよいですか?

4

1 に答える 1

7

ワークフローは次のようになります...
workflow.xml

<workflow-app xmlns="uri:oozie:workflow:0.2" name="hive-wf">
    <start to="hive-node"/>
    <action name="hive-node">
        <hive xmlns="uri:oozie:hive-action:0.2">
           <job-tracker>localhost:50001</job-tracker>
            <name-node>hdfs://localhost:50000</name-node>
            <configuration>
                <property>
                    <name>mapred.job.queue.name</name>
                    <value>default</value>
                </property>
                <property>
                    <name>oozie.hive.defaults</name>
                    <value>/user/user1/oozie/hive-site.xml</value>
                </property>
            </configuration>
            <script>script.q</script>
            <param>INPUT_TABLE=SampleTable</param>
            <param>OUTPUT=/user/user1/output-data/hive</param>
        </hive>
        <ok to="end"/>
        <error to="fail"/>
    </action>
    <kill name="fail">
        <message>Hive failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
    </kill>
    <end name="end"/>
</workflow-app>

したがって、ここでhive-site.xmlは、$ HIVE_HOME/confフォルダーにあるサイトxmlです。
script.qファイルには、実際のハイブクエリが含まれています。select * from ${INPUT_TABLE}


OUTPUTパラメータをどこでどのように使用できますか?

于 2012-05-09T05:15:26.380 に答える