支持任务streaming

[qdaxb]

当前任务按前后顺序依次执行，需要等待一个节点执行完成后再执行下个节点，当单个任务执行时间过长时会增加无用的等待时间。

因此需要增加一种机制，在存在A->B的依赖关系的前提下，A可以流式的将结果传递给B。