org.apache.storm.starter

Class TransactionalGlobalCount

java.lang.Object

org.apache.storm.starter.TransactionalGlobalCount

public class TransactionalGlobalCount
extends Object

This is a basic example of a transactional topology. It keeps a count of the number of tuples seen so far in a database. The source of data and the databases are mocked out as in memory maps for demonstration purposes.

See Also:

Transactional topologies

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransactionalGlobalCount.BatchCount
static class	TransactionalGlobalCount.UpdateGlobalCount
static class	TransactionalGlobalCount.Value

Field Summary

Fields

Modifier and Type	Field and Description
static Map<Integer,List<List<Object>>>	DATA
static Map<String,TransactionalGlobalCount.Value>	DATABASE
static String	GLOBAL_COUNT_KEY
static int	PARTITION_TAKE_PER_BATCH

Constructor Summary

Constructors

Constructor and Description
TransactionalGlobalCount()

Method Summary

Modifier and Type	Method and Description
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

PARTITION_TAKE_PER_BATCH

public static final int PARTITION_TAKE_PER_BATCH

See Also:

Constant Field Values

DATA

public static final Map<Integer,List<List<Object>>> DATA

DATABASE

public static Map<String,TransactionalGlobalCount.Value> DATABASE

GLOBAL_COUNT_KEY

public static final String GLOBAL_COUNT_KEY

See Also:

Constant Field Values

Constructor Detail

TransactionalGlobalCount

public TransactionalGlobalCount()

Method Detail

main

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

Throws:

Exception