streamcruncher.test.func.generic
Class TopSellingItemsUpdateGroupTest

java.lang.Object
  streamcruncher.test.func.OrderGenenerator
      streamcruncher.test.func.generic.TopSellingItemsTest
          streamcruncher.test.func.generic.TopSellingItemsUpdateGroupTest

public abstract class TopSellingItemsUpdateGroupTest
extends TopSellingItemsTest

This is the correct version of the Query as against TopSellingItemsTest. The "Highest X Window" clause provides a facility to specify a group of columns which will be used to identify if a previous entry exists in the Window for that group. If such an entry exists in the Window, then the updated value for the group will replace the older on. If the clause were no used, then the Window will treat the 2 values as 2 unrelated entries and might end up retain both of them in the Window.

Pay close attention to the different results the Query fetches with and without the clause. Observe the last 4 events that get pumped in.

Constructor Summary

TopSellingItemsUpdateGroupTest()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

TopSellingItemsUpdateGroupTest

public TopSellingItemsUpdateGroupTest()