0

我正在编写一个 SCDF spi 实现来支持流和任务应用程序。作为其中的一部分,我们需要在任务完成后执行一些清理操作。

有人可以提供有关 SCDF 是否会在任务完成时获得回调的信息。如果不是,那么执行清理的替代方法是什么。

4

1 回答 1

1

任务是一种短暂且有限的操作。根据您要完成的任务,您可以执行以下操作之一来调用任何自定义清理例程。

1)运行批处理作业的任务,在该作业中,您可以将“n”个步骤定义为工作流的一部分,并且在成功的上游步骤后,最后一步可以调用清理例程。

2)您可以在 SCDF 中有一个流来监听任务完成事件( 这里是一个批处理作业示例),这最终可以启动另一个任务/作业来调用清理例程。

3)您可以定义一个组合任务图(通过Dashboard / shell),其中每个步骤(又名任务)都可以运行其预期的操作,并且在成功转换或失败事件时,您有机会启动清理例程。

于 2018-01-16T19:55:13.067 回答