- 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
-