US 11,755,618 B2
Stateless stream handling and resharding
Ori Modai, Ramat Hasharon (IL); Orit Nissan-Messing, Hod Hasharon (IL); and Yaron Haviv, Tel Mond (IL)
Assigned to Iguazio Systems Ltd., Herzliya (IL)
Filed by Iguazio Systems Ltd., Herzliya (IL)
Filed on Mar. 6, 2018, as Appl. No. 15/913,915.
Prior Publication US 2019/0278863 A1, Sep. 12, 2019
This patent is subject to a terminal disclaimer.
Int. Cl. G06F 16/00 (2019.01); G06F 16/27 (2019.01); G06F 16/23 (2019.01); G06F 16/2455 (2019.01)
CPC G06F 16/278 (2019.01) [G06F 16/2365 (2019.01); G06F 16/24568 (2019.01)] 20 Claims
OG exemplary drawing
 
1. A system comprising:
a processing device; and
a memory coupled to the processing device and storing instructions that, when executed by the processing device, cause the system to perform operations comprising:
generating a first shard comprising one or more messages;
associating the first shard with a first state attribute;
providing the first shard and the first state attribute as an atomic update within a data stream;
requesting the first state attribute from the first shard, wherein the first state attribute comprises a token that reflects a processing capacity of a streaming system;
receiving the first state attribute;
providing a second shard within the data stream based on the received first state attribute; and
adjusting an operation of a message production source of at least one of the one or more messages within the streaming system based on the received token that reflects the processing capacity of the streaming system.