org.apache.streams.kafka

Class KafkaPersistWriter

java.lang.Object

org.apache.streams.kafka.KafkaPersistWriter

All Implemented Interfaces:

Serializable, Runnable, StreamsOperation, StreamsPersistWriter

public class KafkaPersistWriter
extends Object
implements StreamsPersistWriter, Serializable, Runnable

KafkaPersistWriter writes documents to kafka.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Queue<StreamsDatum>	persistQueue
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
KafkaPersistWriter() KafkaPersistWriter constructor
KafkaPersistWriter(Queue<StreamsDatum> persistQueue) KafkaPersistWriter constructor - uses supplied persistQueue.

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
String	getId()
Queue<StreamsDatum>	getPersistQueue()
void	prepare(Object configurationObject)
void	run()
void	setConfig(KafkaConfiguration config)
void	setPersistQueue(Queue<StreamsDatum> persistQueue)
void	start() run persist writer thread
void	stop()
void	write(StreamsDatum entry)

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

Constructor Detail

KafkaPersistWriter

public KafkaPersistWriter()

KafkaPersistWriter constructor

KafkaPersistWriter

public KafkaPersistWriter(Queue<StreamsDatum> persistQueue)

KafkaPersistWriter constructor - uses supplied persistQueue.

Method Detail

setConfig

public void setConfig(KafkaConfiguration config)

start

public void start()

run persist writer thread

stop

public void stop()

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 entry)

Specified by:

write in interface StreamsPersistWriter

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