C G I K O P R S W

C

cleanUp() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

cleanUp() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

client - Variable in class org.apache.streams.amazon.kinesis.KinesisPersistReader

client - Variable in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

G

getId() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

getId() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

I

isRunning() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

K

KinesisPersistReader - Class in org.apache.streams.amazon.kinesis

KinesisPersistReader reads documents from kinesis.

KinesisPersistReader() - Constructor for class org.apache.streams.amazon.kinesis.KinesisPersistReader

KinesisPersistReader constructor - resolves KinesisReaderConfiguration from JVM 'kinesis'.

KinesisPersistReader(KinesisReaderConfiguration) - Constructor for class org.apache.streams.amazon.kinesis.KinesisPersistReader

KinesisPersistReader constructor - uses provided KinesisReaderConfiguration.

KinesisPersistReaderTask - Class in org.apache.streams.amazon.kinesis

KinesisPersistReaderTask reads documents from kinesis on behalf of

KinesisPersistReaderTask(KinesisPersistReader, String, String) - Constructor for class org.apache.streams.amazon.kinesis.KinesisPersistReaderTask

KinesisPersistReaderTask constructor.

KinesisPersistWriter - Class in org.apache.streams.amazon.kinesis

KinesisPersistWriter writes documents to kinesis.

KinesisPersistWriter() - Constructor for class org.apache.streams.amazon.kinesis.KinesisPersistWriter

KinesisPersistWriter constructor - resolves KinesisWriterConfiguration from JVM 'kinesis'.

KinesisPersistWriter(KinesisWriterConfiguration) - Constructor for class org.apache.streams.amazon.kinesis.KinesisPersistWriter

KinesisPersistWriter constructor - uses provided KinesisWriterConfiguration.

O

org.apache.streams.amazon.kinesis - package org.apache.streams.amazon.kinesis

P

persistQueue - Variable in class org.apache.streams.amazon.kinesis.KinesisPersistReader

persistQueue - Variable in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

pollInterval - Variable in class org.apache.streams.amazon.kinesis.KinesisPersistReader

prepare(Object) - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

prepare(Object) - Method in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

R

readAll() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

readCurrent() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

readNew(BigInteger) - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

run() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReaderTask

S

setConfig(KinesisReaderConfiguration) - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

setConfig(KinesisWriterConfiguration) - Method in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

startStream() - Method in class org.apache.streams.amazon.kinesis.KinesisPersistReader

STREAMS_ID - Static variable in class org.apache.streams.amazon.kinesis.KinesisPersistReader

STREAMS_ID - Static variable in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

W

write(StreamsDatum) - Method in class org.apache.streams.amazon.kinesis.KinesisPersistWriter

C G I K O P R S W