streamcruncher.test.func.generic
Class MultiStreamEventGeneratorTest

java.lang.Object
  streamcruncher.test.func.MultiStreamEventGenerator
      streamcruncher.test.func.generic.MultiStreamEventGeneratorTest

Direct Known Subclasses:

MultiStreamEventGeneratorChainTest

public abstract class MultiStreamEventGeneratorTest
extends MultiStreamEventGenerator

This Test demonstrates the use of the Pattern matching features (Multi-Stream Correlation). Events arrive from 3 different Streams, which simulates Objects bearing a unique numbers and passing through 3 different stages. The when..present(..).. clause is used to succinctly describe the Patterns to watch for.

3 "watch-patterns" are defined on the 3 Streams. A 5 second Partition Window is defined on each of the 3 Streams.

Pattern 1) An Event appears in Stage1 and then it arrives in Stage2 but never arrives in Stage3. Even if it does, the Event has expired from Stages 1 and/or 2.

Pattern 2) An Event appears in Stage1 and then it arrives in Stage3 but never arrives in Stage2. Even if it does, the Event has expired from Stages 1 and/or 3.

Pattern 3) An Event appears in Stage1, Stage2 and Stage3 - all before it expires from any of the 3 Stages.

To demonstrate that the other SQL features can still be used in the Alert-Query, the Select clause uses a case..when clause to add a comment based on the absence/presence of columns.

Nested Class Summary

Nested classes/interfaces inherited from class streamcruncher.test.func.MultiStreamEventGenerator

MultiStreamEventGenerator.Event, MultiStreamEventGenerator.EventType

Constructor Summary

MultiStreamEventGeneratorTest()

Method Summary

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiStreamEventGeneratorTest

public MultiStreamEventGeneratorTest()