In a typical streaming scenario, the is often the need for merge information from different inputs. Odysseus provides the Join operator to do a join between different elements from different streams. It is important, that a join in our scenario is always a temporal joins, i.e. only if the validity of the incomming elements overlap the elements can be merged (if the join condition evaluates to true, of cause). See Join for examples on joining streams.
In a join all elements from the left and from the right input are joined. Another scenario is the enrichment of data. Here each incomming element gets enrichs with information from other sources.
Enrichment can be done with:
- The Enrich operator to enrich with local information.
- The WSEnrich operator to enrich an element with information from an external web service.
- The DBEnrich operator to enrich an element with information from a data base.
- The ContextEnrich operator to enrich an element with information from the context store.