Package org.apache.storm.starter.trident

Class TridentWindowingInmemoryStoreTopology

java.lang.Object

org.apache.storm.starter.trident.TridentWindowingInmemoryStoreTopology

public class TridentWindowingInmemoryStoreTopology
extends Object

Sample application of trident windowing which uses inmemory store for storing tuples in window.

Constructor Summary

Constructors

Constructor	Description
TridentWindowingInmemoryStoreTopology()

Method Summary

Modifier and Type	Method	Description
static StormTopology	buildTopology(WindowsStoreFactory windowStore, WindowConfig windowConfig)
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

TridentWindowingInmemoryStoreTopology

public TridentWindowingInmemoryStoreTopology()

Method Detail

buildTopology

public static StormTopology buildTopology(WindowsStoreFactory windowStore,
                                          WindowConfig windowConfig)
                                   throws Exception

Throws:

Exception

main

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

Throws:

Exception