公开(公告)号：US20220261390A1

公开(公告)日：2022-08-18

申请号：US17179315

申请日：2021-02-18

Applicant: Itron, Inc.

Inventor： Wayne Creasey ,  Thomas Kring

IPC: G06F16/22 ,  G06F16/21 ,  H04W76/11 ,  H04W4/38

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.

公开(公告)号：US20230267110A1

公开(公告)日：2023-08-24

申请号：US18140401

申请日：2023-04-27

Applicant: Itron, Inc.

Inventor： Wayne Creasey ,  Thomas Kring

IPC: G06F16/22 ,  G06F16/21 ,  H04W4/38 ,  H04W76/11

CPC classification number: G06F16/2282 ,  G06F16/217 ,  H04W4/38 ,  H04W76/11 ,  G06F16/211

Abstract: A method includes receiving data packets from a stream partition of a plurality of stream partitions, processing the data packets with a plurality of stream processors to generate multiple table entries, transmitting the multiple table entries in batches to a plurality of staging tables, the plurality of staging tables being provided for a respective one of the plurality of stream partitions, and receiving the batches at a target table communicatively coupled to the plurality of staging tables, the batches being transmitted from the plurality of staging tables. The plurality of staging tables are updated in first batches at a first frequency and the target table is updated in second batches at a second frequency, the second frequency being different than the first frequency.

公开(公告)号：US11669508B2

公开(公告)日：2023-06-06

申请号：US17179315

申请日：2021-02-18

Applicant: Itron, Inc.

Inventor： Wayne Creasey ,  Thomas Kring

IPC: G06F16/22 ,  G06F16/21 ,  H04W4/38 ,  H04W76/11

CPC classification number: G06F16/2282 ,  G06F16/211 ,  G06F16/217 ,  H04W4/38 ,  H04W76/11

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.