org.apache.storm.starter.trident

Class TridentReach

java.lang.Object

org.apache.storm.starter.trident.TridentReach

public class TridentReach
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TridentReach.ExpandList
static class	TridentReach.One
static class	TridentReach.StaticSingleKeyMapState

Field Summary

Fields

Modifier and Type	Field and Description
static Map<String,List<String>>	FOLLOWERS_DB
static Map<String,List<String>>	TWEETERS_DB

Constructor Summary

Constructors

Constructor and Description
TridentReach()

Method Summary

Modifier and Type	Method and Description
static StormTopology	buildTopology(org.apache.storm.LocalDRPC drpc)
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

TWEETERS_DB

public static Map<String,List<String>> TWEETERS_DB

FOLLOWERS_DB

public static Map<String,List<String>> FOLLOWERS_DB

Constructor Detail

TridentReach

public TridentReach()

Method Detail

buildTopology

public static StormTopology buildTopology(org.apache.storm.LocalDRPC drpc)

main

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

Throws:

Exception