US 12,120,168 B1Granted

Scalable livestream augmentation system

Assignee1337, Inc.

InventorAndrei Cristea

Life of this patent

Estimating the term…

Loading patent…

Abstract

Systems and methods are described that include receiving, at a streaming server, a data stream; upon determining, by the streaming server, a transformation to be applied to the data stream, transmitting the data stream to a processing server and applying, using the processing server, the transformation to the data stream; generating a transformed data stream for use by a platform. Systems and methods can include applying, using a determined number of processors, the transformation to a plurality of data stream samples, each processor of the determined number of processors applying the transformation to a data stream sample and generating a transformed data stream sample. Systems and methods can apply, using a processor, the transformation to a plurality of data stream sample sequences and generate corresponding transformed data stream sample sequences. Determining the number of processors can be based on a latency budget value and/or an attribute value of the transformation.

Claims18

Dependent claims

A system comprising:

a memory;
and
at least one hardware processor configured to perform operations comprising:
receiving, at a streaming server, a data stream;
receiving, at the streaming server, a request to apply a transformation to the data stream;
upon receiving the request to apply the transformation to the data stream:
determining a first transformation attribute value associated with a sample of the data stream, wherein samples of the data stream are processed in parallel;
determining a second transformation attribute value associated with a sequence of processed data stream samples;
transmitting the data stream to a processing server;
determining a number of processors based on a latency budget value, the first transformation attribute value and the second transformation attribute value;
applying, at the processing server using the determined number of processors, the transformation to the data stream;
and
generating, by the processing server, a transformed data stream for use by a platform;
determining, at the streaming server, an end to applying the transformation to the data stream, the determining comprising detecting a termination trigger;
and
responsive to determining the end to applying the transformation, bypassing the processing server and forwarding the data stream to the platform, the data stream no longer being transformed.

13 more elements

A method comprising:

receiving, at a streaming server, a data stream;
receiving, at the streaming server, a request to apply a transformation to the data stream;
upon receiving the request to apply the transformation to the data stream:
determining a first transformation attribute value associated with a sample of the data stream, wherein samples of the data stream are processed in parallel;
determining a second transformation attribute value associated with a sequence of processed data stream samples;
transmitting the data stream to a processing server;
determining a number of processors based on a latency budget value, the first transformation attribute value and the second transformation attribute value;
applying, at the processing server using the determined number of processors, the transformation to the data stream;
and
generating, by the processing server, a transformed data stream for use by a platform;
determining, at the streaming server, an end to applying the transformation to the data stream, the determining comprising detecting a termination trigger;
and
responsive to determining the end to applying the transformation, bypassing the processing server and forwarding the data stream to the platform, the data stream no longer being transformed.

10 more elements

Dependencies are inferred from the claim text.