org.apache.streams.local.test.writer

Class DatumCounterWriter

java.lang.Object

org.apache.streams.local.test.writer.DatumCounterWriter

All Implemented Interfaces:

Serializable, org.apache.streams.core.StreamsOperation, org.apache.streams.core.StreamsPersistWriter

public class DatumCounterWriter
extends Object
implements org.apache.streams.core.StreamsPersistWriter

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static Set<Integer>	CLAIMED_ID Set of all ids that have been claimed.
static ConcurrentHashMap<String,AtomicLong>	COUNTS The total count of data seen by a all instances of a processor.
static Random	RAND Random instance to generate ids
static ConcurrentHashMap<String,List<Object>>	RECEIVED The documents received
static Set<Integer>	SEEN_DATA Set of instance ids that received data.

Constructor Summary

Constructors

Constructor and Description
DatumCounterWriter(String writerId)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
int	getDatumsCounted()
String	getId()
void	prepare(Object configurationObject)
void	write(org.apache.streams.core.StreamsDatum entry)

Methods inherited from class java.lang.Object

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

Field Detail

CLAIMED_ID

public static Set<Integer> CLAIMED_ID

Set of all ids that have been claimed. Ensures all instances are assigned unique ids

RAND

public static final Random RAND

Random instance to generate ids

SEEN_DATA

public static final Set<Integer> SEEN_DATA

Set of instance ids that received data. Usefully for testing parrallelization is actually working.

COUNTS

public static final ConcurrentHashMap<String,AtomicLong> COUNTS

The total count of data seen by a all instances of a processor.

RECEIVED

public static final ConcurrentHashMap<String,List<Object>> RECEIVED

The documents received

Constructor Detail

DatumCounterWriter

public DatumCounterWriter(String writerId)

Method Detail

getId

public String getId()

Specified by:

getId in interface org.apache.streams.core.StreamsOperation

write

public void write(org.apache.streams.core.StreamsDatum entry)

Specified by:

write in interface org.apache.streams.core.StreamsPersistWriter

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface org.apache.streams.core.StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface org.apache.streams.core.StreamsOperation

getDatumsCounted

public int getDatumsCounted()