Patent ID: 8954724
Filing Date: 2015-02-10
Classification: H04L

Abstract:
1. A method, comprising: providing a plurality of processing elements comprising one or more operators, the operators configured to process streaming data tuples by operation of one or more computer processors; defining attributes of the operators, wherein the attributes comprise at least an access indicator defining processing rules for tuples containing encrypted data; establishing an operator graph of a plurality of operators, the operator graph defining at least one execution path in which a first operator of the plurality of operators is configured to receive data tuples from at least one upstream operator and transmit data tuples to at least one downstream operator; upon receiving a first data stream having a first tuple containing encrypted data in the first operator, determining, based on the access indicator of the first operator, whether to decrypt the encrypted data in the first operator; upon determining that the access indicator of the first operator permits decryption of the encrypted data based on a windowing condition existing within the first operator, decrypting the encrypted data, wherein the windowing condition is defined by the presence of both the first tuple and a predefined set of tuples within a window of the first operator during a predefined period of time; and transmitting the tuple to a second operator, downstream from the first operator.