此模块负责加载和执行已导入到管理数据库中的数据流。此模块通过 SHR Timer Server 进行调用。可以在 {PMDB_HOME}/lib/trendtimer.sched
中找到调度信息。
必须首先加载流,然后才能执行流。将每 12 分钟加载一次流。每 3 分钟执行流步骤一次。
将无法确保已加载的含 4 个步骤的流可在 12 分钟内完成。这是由于产品对步骤执行过程所施加的一些限制条件导致的。这些限制取决于步骤的类型。以下是对应于每种步骤类型的默认设置。
COLLECT_PROC | 10 |
TRANSFORM_PROC |
10 |
RECONCILE_PROC |
10 |
STAGE_PROC | 10 |
LOAD_PROC | 15 |
AGGREGATE_PROC | 10 |
EXEC_PROC_PROC | 10 |
这表明,在默认情况下只能并行运行 15 个加载程序步骤。如果有超过 15 个加载程序有资格在给定时间点运行,则将在当前调用中跳过其余加载程序。为了防止发生匮乏现象,被跳过的步骤的优先级将提高。所以当 abcloadnrun 在下一个第 3 分钟运行时,它将选择那些先前被跳过的步骤。
用法 | |
加载要执行的流 |
|
执行已加载的流 |
|
streamId | 流的业务名称 |
stepId | 流中步骤的业务名称 |