Itron, Inc.
ACTOR-BASED DATA PROCESSING
Last updated:
Abstract:
A system includes a stream partition manager configured to receive data packets input from a plurality of actors, the actors including virtual representations of physical devices, and partition the data packets into a number of stream partitions based at least in part on one or more criteria. The system further includes a plurality of stream processors communicatively coupled to the stream partition manager. Individual stream processors of the plurality of stream processors being configured to receive data packets from a stream partition of the number of stream partitions, process the data packets to generate multiple table entries, and transmit the multiple table entries in batches. The system further includes a target table communicatively coupled to the plurality of stream processors. The target table is configured to receive and store the batches received from the individual stream processors.
Utility
18 Feb 2021
18 Aug 2022