org.apache.streams.cassandra

Class CassandraPersistWriter

java.lang.Object

org.apache.streams.cassandra.CassandraPersistWriter

All Implemented Interfaces:

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

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected List<com.datastax.driver.core.BoundStatement>	insertBatch
protected com.datastax.driver.core.PreparedStatement	insertStatement
protected ReadWriteLock	lock
protected Queue<StreamsDatum>	persistQueue
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
CassandraPersistWriter()
CassandraPersistWriter(CassandraConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
void	close()
void	flush()
protected void	flushIfNecessary()
String	getId()
Queue<StreamsDatum>	getPersistQueue()
void	prepare(Object configurationObject)
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

insertStatement

protected com.datastax.driver.core.PreparedStatement insertStatement

insertBatch

protected List<com.datastax.driver.core.BoundStatement> insertBatch

lock

protected final ReadWriteLock lock

Constructor Detail

CassandraPersistWriter

public CassandraPersistWriter()

CassandraPersistWriter

public CassandraPersistWriter(CassandraConfiguration 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()