Satori Worldwide, LLC

Datadog, Inc.

Other

Koninklijke Philips Corporation N.v.

Boaz Sedan

Francois Orsini

Anton Koinov

Oleg Khabinov

Fredrik Erik Linder

Igor Milyakov

Bartlomiej Puzon

Cynthia Chu

Geraud Louis Boyer

Gabriel Leydon

Arun Kejariwal

Andrey Kushnir

Steven Brooks

Jared Stoffan

Mick Ryan

Renee Ya

Dhruv Choudhary

Mikhail Kuzmiankou

Alex Taylor

Nika Kolomentseva

Winnie Tseng-Mueller

Sarit Arcushin-Yaakobovitz

Andrey Kolomentsev

Kyle Lau

Sujesha Sudevalayam

Mykhailo Aizatskyi

Anna Kareva

Gabor Mueller-Tseng

A monitoring system is configured for de-duplicating data for storing in a database. The monitoring system is configured for receiving a message including a sequence of fields and corresponding field values; generating an entry in a first mapping table that associates each unique field and each unique field value of the message to a corresponding index value that is unique; generating a first vector including index values; ordering the index values of the vector, the ordered index values indicating a structure of the message; generating an entry in a second mapping table that associates the structure of the message with a structure index value; generating a second vector including the structure index value and an ordered set of index values representing the field values; and storing, in a database, the second vector.

Analytics database and monitoring system for structuring and storing data streams

A ring replication system receives and redundantly stores electronic data for access by users. Two or more storage devices are configured in a ring and circulate received data to each other. At least one such device receives incoming data records from an external source. One storage device is designated as the ordering device for assigning a sequence order to each data record, and the assigned sequence order is circulated around the ring. After confirming that the assigned sequence order has been indexed within each storage device on the ring, data records may then be accessed by users. One or more access portals may be coupled to one or more storage devices in the replication ring for providing users with access to stored data records. Data records are accessed in accordance with the assigned sequence order. A related method for redundant storage of data records is also disclosed.

Ring replication system

Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for assigning channels in a messaging system. An example method includes: providing a plurality of channels, wherein each channel includes an ordered plurality of messages; assigning each channel to a channel bucket to form a plurality of channel buckets, wherein each channel bucket includes at least two channels from the plurality of channels; and assigning each channel bucket to a node selected from a plurality of nodes, wherein the node includes one or more buffers for storing messages according to the order from the channel buckets of the node.

Channel management in scalable messaging system

Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for managing or tracking assets in a geographical area. One method includes receiving one or more first messages from a plurality of assets on one or more first channels of a plurality of channels. The one or more first messages may indicate live geographical locations of the plurality of assets located in a geographical area. The method also includes displaying, via a graphical user interface, the live geographical locations of the plurality of assets on a map of the geographical area. The method further includes receiving on a second channel a message indicating a request from a first user device to travel to a destination. The method further includes determining one or more travel routes to the destination. The one or more travel routes may use different assets to transport the first user device to the destination. The method further includes publishing on a third channel one or more second messages indicating the one or more travel routes.

Systems and methods for managing assets in a geographical location

Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for managing channels in an open data ecosystem. A method includes providing one or more graphical user interfaces to a first user of an open data ecosystem. The open data ecosystem includes a plurality of public channels and a plurality of private channels. The users of the open data ecosystem are able to receive messages on each of the plurality of public channels. The method also includes receiving first user input from the first user via the one or more graphical user interfaces. The method further includes configuring one or more channels of the plurality of public channels or the plurality of private channels based on the first user input received from the first user via the one or more graphical user interfaces.

Managing channels in an open data ecosystem

Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for implementing key-value store functionality within a real-time messaging system. An example method includes: providing a plurality of channels, wherein each channel comprises an ordered plurality of messages, wherein each channel represents a unique key, and wherein each message comprises one or more key-value pairs; receiving a function comprising a key for identifying one of the plurality of channels and processing instructions to be applied to a subset of the key-value pairs; and applying the processing instructions based at least in part on the unique key.

Data storage systems and methods using a real-time messaging system

Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for providing a video to subscribers of a messaging system. A method includes obtaining a live video stream generated by a video source. The method also includes publishing one or more messages including one or more frames of the live video stream to a first channel of a plurality of channels. The video source is associated with the first channel.

Providing video to subscribers of a messaging system

Methods, systems, and apparatus, including computer programs encoded on a computer storage medium, for selective distribution of messages from a scalable, real-time messaging system. An example method includes: receiving query instructions from a subscriber client, wherein the subscriber client is subscribed to a channel of a plurality of channels; receiving a plurality of messages from a plurality of publisher clients, wherein each message is associated with a particular one of the plurality of channels; applying the query instructions to the plurality of messages for the channel as the messages are received; and sending the messages resulting from the application of the query instructions to the subscriber client, wherein the messages received by the subscriber client from the channel are limited to those that satisfy the query instructions.

Selective distribution of messages in a scalable, real-time messaging system

A system for encoding web accessible high quality medical images () includes one or more processors () and one or more servers (). The one or more processors a reprogrammed to divide () the high quality medical image into multiple 8 bit files () by bit location in each pixel of the high quality medical image () and padding bits in each file to total 8 bits where the divided number of bits from the high quality medical is less than 8 bits. The one or more processors compress () each 8 bit file. The one or more servers () are configured to send the compressed files in response to a hyper-text transport protocol(HTTP) request for the high quality medical image ().

Encoding high quality (medical) images using standard lower quality (web) image formats

Growing community of inventors

Palo Alto, CA, United States of America

Boaz Sedan