Stream processing with context data affinity
First Claim
1. A computer-implemented method comprising:
- receiving an event at a first computing node of a stream processing system, the stream processing system comprising a plurality of computing nodes, wherein each computing node of the stream processing system has installed a same stream processing topology of functional modules, wherein context data related to events received by the stream processing system is partitioned among the plurality of computing nodes, and wherein each partition of context data is stored in operational memory of each respective computing node;
obtaining, by the first computing node of the plurality of computing nodes, context data related to the event from operational memory of the first computing node;
processing, by the first computing node, an operation of a functional module of the stream processing topology using the context data obtained from the operational memory of the first computing node; and
providing, to a subsequent functional module of the stream processing topology, a modified event according to the operation of the functional module of the stream processing topology.
1 Assignment
0 Petitions
Accused Products
Abstract
Methods, systems, and apparatus, including computer programs encoded on computer storage media, for stream processing with contextual data affinity. One of the methods includes receiving an event at a computing node of a stream processing system that includes one or more computing nodes and data representing a topology of functional modules. At a particular functional module of the topology, an operation that requests access to context data related to the event is determined based on a data attribute of the event. The context data is partitioned among the one or more computing nodes. Context data related to the event is obtained from the computing node. The operation of the particular functional module is processed using the context data, and a modified event is generated. The modified event is provided to a subsequent functional module according to the topology of functional modules.
-
Citations
24 Claims
-
1. A computer-implemented method comprising:
-
receiving an event at a first computing node of a stream processing system, the stream processing system comprising a plurality of computing nodes, wherein each computing node of the stream processing system has installed a same stream processing topology of functional modules, wherein context data related to events received by the stream processing system is partitioned among the plurality of computing nodes, and wherein each partition of context data is stored in operational memory of each respective computing node; obtaining, by the first computing node of the plurality of computing nodes, context data related to the event from operational memory of the first computing node; processing, by the first computing node, an operation of a functional module of the stream processing topology using the context data obtained from the operational memory of the first computing node; and providing, to a subsequent functional module of the stream processing topology, a modified event according to the operation of the functional module of the stream processing topology. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8)
-
-
9. A stream processing system comprising:
-
one or more computing nodes, wherein each computing node of the stream processing system has installed a same stream processing topology of functional modules, wherein context data related to events received by the stream processing system is partitioned among the plurality of computing nodes, and wherein each partition of context data is stored in operational memory of each respective computing node, and one or more storage devices storing instructions that are operable, when executed by the one or more computing nodes, to cause the one or more computing nodes to perform operations comprising; receiving an event at a first computing node of the stream processing system, obtaining, by the first computing node of the plurality of computing nodes, context data related to the event from operational memory of the first computing node; processing, by the first computing node, an operation of a functional module of the stream processing topology using the context data obtained from the operational memory of the first computing node; and providing, to a subsequent functional module of the stream processing topology, a modified event according to the operation of the functional module of the stream processing topology. - View Dependent Claims (10, 11, 12, 13, 14, 15, 16)
-
-
17. A computer program product, encoded on one or more non-transitory computer storage media, comprising instructions that when executed by one or more computers cause the one or more computers to perform operations comprising:
-
receiving an event at a first computing node of a stream processing system, the stream processing system comprising a plurality of computing nodes, wherein each computing node of the stream processing system has installed a same stream processing topology of functional modules, wherein context data related to events received by the stream processing system is partitioned among the plurality of computing nodes, and wherein each partition of context data is stored in operational memory of each respective computing node; obtaining, by the first computing node of the plurality of computing nodes, context data related to the event from operational memory of the first computing node; processing, by the first computing node, an operation of a functional module of the stream processing topology using the context data obtained from the operational memory of the first computing node; and providing, to a subsequent functional module of the stream processing topology, a modified event according to the operation of the functional module of the stream processing topology. - View Dependent Claims (18, 19, 20, 21, 22, 23, 24)
-
Specification