MANAGING ATTRIBUTES IN STREM PROCESSING USING A CACHE

摘要

A method and system for managing attributes in a streaming application is disclosed. The system may contain a receiving stream operator that is communicatively coupled with a stream manager. The receiving stream operator may have a capability of storing a selected attribute and creating one or more unique identifiers. The system may contain a cache communicatively coupled with one or more stream operators. The cache may have a capability of storing the selected attributes. The system may also have a retrieving stream operator communicatively coupled with the stream manager. The retrieving stream operator may have a capability of using the unique identifier to access the selected attribute.

主权项

1. A system for referencing attributes from a stream of tuples, comprising:
a plurality of processing elements capable of receiving a stream of tuples; a stream manager communicatively coupled with the processing elements having a capability of monitoring attributes in tuples, wherein one or more selected attributes are selected from a group of candidate attributes; a receiving stream operator communicatively coupled with the stream manager and having a capability of storing the selected attribute and creating one or more unique identifiers; a cache communicatively coupled with one or more stream operators having a capability of storing the selected attributes; and a retrieving stream operator communicatively coupled with the stream manager having a capability of using the unique identifier to access the selected attribute.