Skip to main content
Version: 0.93.0

Synchronize Two Streams


Description

Merges two event streams by their timestamp. Two events of the different streams are merged when they occure to the same time

The following figure shows how the events of the two data streams will be mergrged:


Required input

Each of the data streams needs a timestamp.


Configuration

  • For each stream a the timestamp property on which the merger is performed has to be selected
  • The Time Interval describes the maximum value between two events to decide whether they are a match. To be a valid match the following function must be true: | timestamp_stream_1 - timestamp_stream_2 | < interval

Output

The Compose processor has a configurable output that can be selected by the user at pipeline modeling time.