streamcruncher.test.func.generic
Class TopSellingItemsTest

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

Direct Known Subclasses:

TopSellingItemsUpdateGroupTest

public abstract class TopSellingItemsTest
extends OrderGenenerator

This example along with TopSellingItemsUpdateGroupTest shows how Chained Partitions and the "Highest X elements Window" can be used to keep track of the top selling items in a Store.

Here, Orders are placed and the total quantities are stored at "Country > State > City > Item SKU" level. The sum is a rolling-sum over a 30 day period. Everytime the Sum changes, it is fed to the Partition down the chain, which stores the top 3 products per Country/State/City, whose total quantities exceed all other products.

Constructor Summary

TopSellingItemsTest()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

TopSellingItemsTest

public TopSellingItemsTest()