public class KafkaPersistWriter extends Object implements StreamsPersistWriter, Serializable, Runnable
Modifier and Type | Field and Description |
---|---|
protected Queue<StreamsDatum> |
persistQueue |
static String |
STREAMS_ID |
Constructor and Description |
---|
KafkaPersistWriter()
KafkaPersistWriter constructor
|
KafkaPersistWriter(Queue<StreamsDatum> persistQueue)
KafkaPersistWriter constructor - uses supplied persistQueue.
|
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) |
public static final String STREAMS_ID
protected volatile Queue<StreamsDatum> persistQueue
public KafkaPersistWriter()
public KafkaPersistWriter(Queue<StreamsDatum> persistQueue)
public void setConfig(KafkaConfiguration config)
public void start()
public void stop()
public void setPersistQueue(Queue<StreamsDatum> persistQueue)
public Queue<StreamsDatum> getPersistQueue()
public String getId()
getId
in interface StreamsOperation
public void write(StreamsDatum entry)
write
in interface StreamsPersistWriter
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
public void cleanUp()
cleanUp
in interface StreamsOperation
Copyright © 2018 The Apache Software Foundation. All rights reserved.