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(KinesisWriterConfiguration config) |
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 © 2012–2016 The Apache Software Foundation. All rights reserved.