org.apache.streams.mongo

Class MongoPersistWriter

java.lang.Object

org.apache.streams.mongo.MongoPersistWriter

All Implemented Interfaces:

Closeable, Flushable, Serializable, AutoCloseable, Runnable, StreamsOperation, StreamsPersistWriter

public class MongoPersistWriter
extends Object
implements StreamsPersistWriter, Runnable, Flushable, Closeable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected com.mongodb.MongoClient	client
protected com.mongodb.DBCollection	collection
protected com.mongodb.DB	db
protected List<com.mongodb.DBObject>	insertBatch
protected ReadWriteLock	lock
protected Queue<StreamsDatum>	persistQueue
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
MongoPersistWriter()
MongoPersistWriter(MongoConfiguration config)

Method Summary

Modifier and Type	Method and Description
protected void	addToBatch(com.mongodb.DBObject dbObject)
void	cleanUp()
void	close()
void	flush()
protected void	flushIfNecessary()
String	getId()
Queue<StreamsDatum>	getPersistQueue()
void	prepare(Object configurationObject)
protected com.mongodb.DBObject	prepareObject(StreamsDatum streamsDatum)
void	run()
void	setPersistQueue(Queue<StreamsDatum> persistQueue)
void	start() start write thread.
void	stop() stop.
void	write(StreamsDatum streamsDatum)

Methods inherited from class java.lang.Object

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

Field Detail

STREAMS_ID

public static final String STREAMS_ID

See Also:

Constant Field Values

persistQueue

protected volatile Queue<StreamsDatum> persistQueue

client

protected com.mongodb.MongoClient client

db

protected com.mongodb.DB db

collection

protected com.mongodb.DBCollection collection

insertBatch

protected List<com.mongodb.DBObject> insertBatch

lock

protected final ReadWriteLock lock

Constructor Detail

MongoPersistWriter

public MongoPersistWriter()

MongoPersistWriter

public MongoPersistWriter(MongoConfiguration config)

Method Detail

setPersistQueue

public void setPersistQueue(Queue<StreamsDatum> persistQueue)

getPersistQueue

public Queue<StreamsDatum> getPersistQueue()

getId

public String getId()

Specified by:

getId in interface StreamsOperation

write

public void write(StreamsDatum streamsDatum)

Specified by:

write in interface StreamsPersistWriter

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

start

public void start()

start write thread.

stop

public void stop()

stop.

run

public void run()

Specified by:

run in interface Runnable

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

flushIfNecessary

protected void flushIfNecessary()

addToBatch

protected void addToBatch(com.mongodb.DBObject dbObject)

prepareObject

protected com.mongodb.DBObject prepareObject(StreamsDatum streamsDatum)