C E F G H I K O P R S T V 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

E

equals(Object) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

equals(Object) - Method in class org.apache.streams.amazon.kinesis.KinesisReaderConfiguration

equals(Object) - Method in class org.apache.streams.amazon.kinesis.KinesisWriterConfiguration

F

fromValue(String) - Static method in enum org.apache.streams.amazon.kinesis.KinesisConfiguration.Protocol

G

getAdditionalProperties() - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

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

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

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

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

getKey() - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

Your Amazon Key (Required)

getProtocol() - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

Whether you are using HTTP or HTTPS

getRegion() - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

The AWS region where your bucket resides

getSecretKey() - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

Your Amazon Secret Key (Required)

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

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

H

hashCode() - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

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

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

I

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

K

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

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

KinesisConfiguration.Protocol - Enum in org.apache.streams.amazon.kinesis

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.

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

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

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

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

setAdditionalProperty(String, Object) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.amazon.kinesis.KinesisReaderConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.amazon.kinesis.KinesisWriterConfiguration

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

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

setKey(String) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

Your Amazon Key (Required)

setProtocol(KinesisConfiguration.Protocol) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

Whether you are using HTTP or HTTPS

setRegion(String) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

The AWS region where your bucket resides

setSecretKey(String) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

Your Amazon Secret Key (Required)

setStream(String) - Method in class org.apache.streams.amazon.kinesis.KinesisWriterConfiguration

setStreams(List<String>) - Method in class org.apache.streams.amazon.kinesis.KinesisReaderConfiguration

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

T

toString() - Method in enum org.apache.streams.amazon.kinesis.KinesisConfiguration.Protocol

toString() - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

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

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

V

valueOf(String) - Static method in enum org.apache.streams.amazon.kinesis.KinesisConfiguration.Protocol

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.streams.amazon.kinesis.KinesisConfiguration.Protocol

Returns an array containing the constants of this enum type, in the order they are declared.

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.amazon.kinesis.KinesisReaderConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.amazon.kinesis.KinesisWriterConfiguration

withKey(String) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

withProtocol(KinesisConfiguration.Protocol) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

withRegion(String) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

withSecretKey(String) - Method in class org.apache.streams.amazon.kinesis.KinesisConfiguration

withStream(String) - Method in class org.apache.streams.amazon.kinesis.KinesisWriterConfiguration

withStreams(List<String>) - Method in class org.apache.streams.amazon.kinesis.KinesisReaderConfiguration

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

C E F G H I K O P R S T V W