org.apache.storm.starter.trident

Class TridentHBaseWindowingStoreTopology

java.lang.Object

org.apache.storm.starter.trident.TridentHBaseWindowingStoreTopology

public class TridentHBaseWindowingStoreTopology
extends Object

Sample application of trident windowing which uses HBaseWindowsStoreFactory’s store for storing tuples in window.

Constructor Summary

Constructors

Constructor and Description
TridentHBaseWindowingStoreTopology()

Method Summary

Modifier and Type	Method and Description
static StormTopology	buildTopology(WindowsStoreFactory windowsStore)
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

TridentHBaseWindowingStoreTopology

public TridentHBaseWindowingStoreTopology()

Method Detail

buildTopology

public static StormTopology buildTopology(WindowsStoreFactory windowsStore)
                                   throws Exception

Throws:

Exception

main

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

Throws:

Exception