streamcruncher.test.func.generic
Class StockPriceComparisonTest

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

public abstract class StockPriceComparisonTest
extends MultiStreamEventGenerator

This Test demonstrates the use of the self# keyword to perform Self-Joins across a Partition. Self-Joins are very useful when we are trying to look for a related Event inside the same Partition Window. Instead of having to define multiple identical Partitions and then joining them, this method lets the user create a single Partition first and then create references to the same Partition using different aliases.

In this Test, a Sliding Window of size 3 is defined on a Stream of Stock Quotes for a specific symbol. The intention is to retrieve Stock Price pairs such that the latest price is atleast 2 Dollars higher than the previous 2 prices (still in the Window).

This test uses only one Stream. The other Streams are dormant.

Nested Class Summary

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

MultiStreamEventGenerator.Event, MultiStreamEventGenerator.EventType

Constructor Summary

StockPriceComparisonTest()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

StockPriceComparisonTest

public StockPriceComparisonTest()