Browse Prior Art Database

Mechanism for maintaining bitemporal state in the presence of multiple event streams

IP.com Disclosure Number: IPCOM000245747D
Publication Date: 2016-Apr-04
Document File: 2 page(s) / 39K

Publishing Venue

The IP.com Prior Art Database

Abstract

Described is a mechanism for maintaining bitemporal state in the presence of multiple event streams. The addition of a stream of graph cuts to a diverse collection of streams provides discernment of state validity.

This text was extracted from a PDF file.
This is the abbreviated version, containing approximately 59% of the total text.

Page 01 of 2

Mechanism for maintaining bitemporal state in the presence of multiple event streams

Whether assessing investment risk based on news streams or coordinating changes from multiple developers in a source control system, there are a variety of applications for stream processing style applications. However, in the presence of a diverse collection of streams, applications which require the ability to determine state at any given time (bitemporal functionality) must currently resort to using timestamps with no ability to determine the validity of a particular point in time. Proposed here is a method to provide functionality analogous to a database commit operation to record points in time where the global state is valid, thereby allowing movement through time from one valid state to the next. Once a valid state is known, further exploration by playing forward or rewinding individual streams is also possible.

    The proposed solution is to augment the collection of streams, adding a stream of graph cuts to the collection. Each cut will contain the list of identifiers for each stream representing a valid global state. The events on the new stream can be entered manually, via a commit-like API (essentially taking a snapshot of the head of each of the member streams), via some automated mechanism such as automatic commits, or via some time-based approach based on quiescence of the member streams.

    The figure below shows an example application comprised of a new stream, a pric...