用于优化流处理程序的方法、装置和系统

摘要

一系统基于在流处理程序之间交换的数据来优化两个或两个以上流处理程序。所述系统交替地处理每一流处理程序以识别并去除失效程序代码，藉此改进执行性能。通过传播作为来自其它流处理程序的输入而接收到的常数且通过分析一第一流处理程序并确定一第二流处理程序的未被所述第一流处理程序使用的输出来识别失效程序代码。所述系统可执行此优化的多次重复，因为先前的重复引入了用作一流处理程序的输入的附加常数。在所述流处理程序的优化之后，将所述经优化的流处理程序编译为一适于由一流处理系统执行的格式。

主权项

1. 一种用于优化用于由一流处理系统执行的流处理程序的方法，其中所述流处理系统包括一第一和一第二可编程流处理单元，其中所述第二流处理单元与所述第一流处理单元连接，使得所述第一流处理单元的输出用于作为所述第二流处理单元的输入，所述方法包含：接收一用于由一第一流处理单元执行的第一流处理程序，其中所述第一流处理程序包括一输出参数；接收一用于由一第二流处理单元执行的第二流处理程序，其中所述第二流处理程序包括一对应于所述第一流处理程序的所述输出参数的输入参数；和基于所述第二流处理程序的所述输入参数与所述第一流处理程序的所述输出参数之间的对应来优化所述第一和第二流处理程序。