Package org.apache.storm.starter.streams

Class GroupByKeyAndWindowExample

java.lang.Object

org.apache.storm.starter.streams.GroupByKeyAndWindowExample

public class GroupByKeyAndWindowExample
extends Object

An example that shows the usage of PairStream.groupByKeyAndWindow(Window) and PairStream.reduceByKeyAndWindow(Reducer, Window).

Constructor Summary

Constructors

Constructor	Description
GroupByKeyAndWindowExample()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupByKeyAndWindowExample

public GroupByKeyAndWindowExample()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception