Vmware, Inc.

Kostadin Georgiev

Christos Karamanolis

Richard Paul Spillane

Abhishek Gupta

Deyan Popov

Lyubomir Tzvetkov

Dimiter Dimitriev

Distributed appending of transactions in data lakes is described. A first message is received, at a first ingestion node of a plurality of ingestion nodes, as part of a transaction. The first message identifies a transaction identifier (ID) and a portion of data for the transaction. The data of the first message is persisted in temporary storage. A count of messages for the transaction for the first ingestion node is determined. Based on at least the count of messages, it is determined that the first ingestion node has received a complete set of messages for the transaction for the first ingestion node. A metadata write request is transmitted, by the first ingestion node, to a coordinator. The metadata write request includes a self-describing reference to persisted data. The self-describing reference identifies the first ingestion node, location information of the persisted data, and a range of the first data.

Distributed appending of transactions in data lakes

Disclosed are various embodiments for scalable notification deliveries in computing environments. A subscription request is transmitted along with a user identifier, a service identifier, a subscription identifier, and a channel identifier. Notifications are communicated through a notification multiplexing channel between two nodes of a computing environment. The notification multiplexing channel includes notifications multiplexed by subscription identifiers. The notification multiplexing channel corresponds to the channel identifier. A notification corresponding to the subscription identifier is identified and provided to a client computing device associated with the user identifier.

Scalable notification delivery for networked computing environments

Growing community of inventors

Sofia, Bulgaria

Kostadin Georgiev