COMPILE-TIME TUPLE ATTRIBUTE COMPRESSION

摘要

A method, system, and computer program product for initializing a stream computing application are disclosed. The method may include, during a compiling of code, determining whether an attribute of a tuple to be processed at a first stream operator is to be next processed at a second stream operator. The first stream operator may be configured to transmit the tuple along an execution path to the second stream operator. The execution path includes one or more intervening stream operators between the first and second stream operators. The method may invoke a compression condition when the first attribute of the tuple to be processed at the first stream operator is to be next processed at the second stream operator.

主权项

1. A method for initializing a stream computing application for execution on one or more compute nodes, each compute node adapted to execute one or more stream operators, the method including compiling code, comprising:
determining whether a first attribute to be processed at a first stream operator is to be next processed at a second stream operator, the first stream operator configured to transmit a tuple along an execution path including one or more intervening stream operators to the second stream operator; and invoking a compression condition when the first attribute to be processed at the first stream operator is to be next processed at the second stream operator.