| 摘要 |
Managing task execution includes: receiving a specification of a plurality of tasks (442, 444, 446) to be performed by respective functional modules; processing a flow of input data (402, 404, 406) using a dataflow graph that includes nodes representing data processing components (410) connected by links representing flows of data between data processing components; in response to at least one flow of data provided by at least one data processing component (410), generating a flow of messages (422); and in response to each of the messages in the flow of messages, performing an iteration of a set of one or more tasks (442) using one or more corresponding functional modules. |
