Subsumption architecture for processing fragments of a video stream
AssigneeRicoh Company, Ltd.
InventorsHector H. Gonzalez-Banos, Max McFarland, Ramya Narasimha
Life of this patent
Estimating the term…
Abstract
The disclosure includes a system and method for distributing video segments of a video to one or more brokers based on topics and storing the video segments in a distributed commit log associated with the topics. A video processing application decomposes a video into fragments, groups the fragments into topics based on identifiers associated with the fragments, breaks the fragments into a sequence of segments, distributes the sequence of segments to one or more brokers based on the topics, and stores, by the one or more brokers, the sequence of segments associated with a topic in a distributed commit log while preserving a sequence order of the sequence of segments.
Claims20
A computer-implemented method comprising:
- decomposing a video into fragments;
- breaking the fragments into a sequence of segments, each fragment being associated with a topic;
- writing the sequence of segments in a plurality of commit logs that are part of a distributed commit log by appending the sequence of segments to an end of each partition of each commit log of the plurality of commit logs based on the topic to preserve a sequence order of the sequence of segments;
- receiving first sensor data including positioning data;
- receiving second sensor data including volume occupancy data;
- filtering the first sensor data by using the second sensor data as a first control sequence to generate an output sequence;
- reading the distributed commit log for the sequence of segments;
- and
- using the output sequence as a second control sequence to filter the sequence of segments to identify a subset of the sequence of segments for provision.
A system comprising:
- one or more processors;
- and
- a memory, the memory storing instructions, which when executed cause the one or more processors to:
- decompose a video into fragments;
- break the fragments into a sequence of segments, each fragment being associated with a topic;
- write the sequence of segments in a plurality of commit logs that are part of a distributed commit log by appending the sequence of segments to an end of each partition of each commit log of the plurality of commit logs based on the topic to preserve a sequence order of the sequence of segments;
- receive first sensor data including positioning data;
- receive second sensor data including and volume occupancy data;
- filter the first sensor data by using the second sensor data as a first control sequence to generate an output sequence;
- read the distributed commit log for the sequence of segments;
- and
- use the output sequence as a second control sequence to filter the sequence of segments to identify a subset of the sequence of segments for provision.
A computer program product comprising a non-transitory computer readable medium storing a computer readable program, wherein the computer readable program when executed causes a computer to:
- decompose a video into fragments;
- break the fragments into a sequence of segments, each fragment being associated with a topic;
- write the sequence of segments in a plurality of commit logs that are part of a distributed commit log by appending the sequence of segments to an end of each partition of each commit log of the plurality of commit logs based on the topic to preserve a sequence order of the sequence of segments;
- receive first sensor data including positioning data;
- receive second sensor data including volume occupancy data;
- filter the first sensor data by using the second sensor data as a first control sequence to generate an output sequence;
- read the distributed commit log for the sequence of segments;
- and
- use the output sequence as a second control sequence to filter the sequence of segments to identify a subset of the sequence of segments for provision.
Dependencies are inferred from the claim text.