streamcruncher.test.func.generic
Class TimeWF1ChainedPartitionTest

java.lang.Object
  streamcruncher.test.func.OrderGenenerator
      streamcruncher.test.func.generic.OrderGeneratorTest
          streamcruncher.test.func.generic.TimeWF1ChainedPartitionTest

public abstract class TimeWF1ChainedPartitionTest
extends OrderGeneratorTest

This Test demonstrates the "Chained Partition" feature, where a series of Partitions can be tied together like a pipeline, with the "to" clause.

The first Partition creates a 5 second Window with aggregates on it. This is then fed to a second Partition, which picks up only the aggregated Events whose values are between 10 and 30 and holds them for 5 seconds. The second Partition only picks up the aggregates that replace the old aggregates.

Constructor Summary

TimeWF1ChainedPartitionTest()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeWF1ChainedPartitionTest

public TimeWF1ChainedPartitionTest()