public class KinesisPersistWriter extends Object implements StreamsPersistWriter
Modifier and Type | Field and Description |
---|---|
protected com.amazonaws.services.kinesis.AmazonKinesisClient |
client |
protected Queue<StreamsDatum> |
persistQueue |
static String |
STREAMS_ID |
Constructor and Description |
---|
KinesisPersistWriter()
KinesisPersistWriter constructor - resolves KinesisWriterConfiguration from JVM 'kinesis'.
|
KinesisPersistWriter(KinesisWriterConfiguration config)
KinesisPersistWriter constructor - uses provided KinesisWriterConfiguration.
|
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
String |
getId() |
void |
prepare(Object configurationObject) |
void |
setConfig(KinesisWriterConfiguration config) |
void |
write(StreamsDatum entry) |
public static final String STREAMS_ID
protected volatile Queue<StreamsDatum> persistQueue
protected com.amazonaws.services.kinesis.AmazonKinesisClient client
public KinesisPersistWriter()
public KinesisPersistWriter(KinesisWriterConfiguration config)
public void setConfig(KinesisWriterConfiguration config)
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.