org.apache.storm.starter

Class TransactionalWords

java.lang.Object

org.apache.storm.starter.TransactionalWords

public class TransactionalWords
extends Object

This class defines a more involved transactional topology then TransactionalGlobalCount. This topology processes a stream of words and produces two outputs:

1. A count for each word (stored in a database) 2. The number of words for every bucket of 10 counts. So it stores in the database how many words have appeared 0-9 times, how many have appeared 10-19 times, and so on.

A batch of words can cause the bucket counts to decrement for some buckets and increment for others as words move between buckets as their counts accumulate.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransactionalWords.BucketCountUpdater
static class	TransactionalWords.Bucketize
static class	TransactionalWords.BucketValue
static class	TransactionalWords.CountValue
static class	TransactionalWords.KeyedCountUpdater

Field Summary

Fields

Modifier and Type	Field and Description
static Map<Integer,TransactionalWords.BucketValue>	BUCKET_DATABASE
static int	BUCKET_SIZE
static Map<String,TransactionalWords.CountValue>	COUNT_DATABASE
static Map<Integer,List<List<Object>>>	DATA
static int	PARTITION_TAKE_PER_BATCH

Constructor Summary

Constructors

Constructor and Description
TransactionalWords()

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

BUCKET_SIZE

public static final int BUCKET_SIZE

See Also:

Constant Field Values

COUNT_DATABASE

public static Map<String,TransactionalWords.CountValue> COUNT_DATABASE

BUCKET_DATABASE

public static Map<Integer,TransactionalWords.BucketValue> BUCKET_DATABASE

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

Constructor Detail

TransactionalWords

public TransactionalWords()

Method Detail

main

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

Throws:

Exception