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 ofPairStream.groupByKeyAndWindow(Window)andPairStream.reduceByKeyAndWindow(Reducer, Window).
-
-
Constructor Summary
Constructors Constructor Description GroupByKeyAndWindowExample()
-