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() - Constructor for class org.apache.streams.amazon.kinesis.KinesisPersistReader

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

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

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

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

Created by sblackmon on 9/2/15.

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

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

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