Serialized Form

Package org.apache.streams.amazon.kinesis

Class org.apache.streams.amazon.kinesis.KinesisConfiguration extends Object implements Serializable

Serialized Fields

key

String key

Your Amazon Key (Required)

secretKey

String secretKey

Your Amazon Secret Key (Required)

protocol

KinesisConfiguration.Protocol protocol

Whether you are using HTTP or HTTPS

region

String region

The AWS region where your bucket resides

additionalProperties

Map<K,V> additionalProperties

Class org.apache.streams.amazon.kinesis.KinesisPersistReader extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

config

KinesisReaderConfiguration config

pollInterval

Long pollInterval

streamNames

List<E> streamNames

executor

ExecutorService executor

client

com.amazonaws.services.kinesis.AmazonKinesisClient client

Class org.apache.streams.amazon.kinesis.KinesisPersistWriter extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

config

KinesisWriterConfiguration config

streamName

List<E> streamName

executor

ExecutorService executor

client

com.amazonaws.services.kinesis.AmazonKinesisClient client

Class org.apache.streams.amazon.kinesis.KinesisReaderConfiguration extends KinesisConfiguration implements Serializable

Serialized Fields

streams

List<E> streams

additionalProperties

Map<K,V> additionalProperties

Class org.apache.streams.amazon.kinesis.KinesisWriterConfiguration extends KinesisConfiguration implements Serializable

Serialized Fields

stream

String stream

additionalProperties

Map<K,V> additionalProperties