hadoop - 使用不同的输入值运行相同的协调器

Question

我有一个协调器，我想用不同的输入值运行它。例如，下面是提供的“输入事件”。我想使用以下参数“苯_hbase_input_offset”值运行协调器作业：

1. (-24) - 查看过去 24 小时的数据。
2. (-96) - 查看过去 96 小时的数据。

现在我只运行选项'2'。为了避免代码重复，我想为“start-instance”参数运行相同的协调器，但输入不同。我怎样才能做到这一点？

<input-events>
    <data-in name="benzene_dwell_calc-output" dataset="BENZENE_DWELL_CALC_OUTPUT">
        <start-instance>${coord:current(benzene_hbase_input_offset)}</start-instance>
        <end-instance>${coord:current(-1)}</end-instance>
    </data-in>
    <data-in name="benzene_dwell_calc-output" dataset="BENZENE_DWELL_CALC_OUTPUT">
        <start-instance>${coord:current(benzene_hbase_input_offset)}</start-instance>
        <end-instance>${coord:current(-1)}</end-instance>
    </data-in>
</input-events>

Answer 1

在 jog.properties 中设置此参数。在 coordinator 中，将其放在 start 实例中，并将其放在 coordinator 名称中，以便您可以区分两者