A B C D E F G H I J K M P R S T U W

A

AllPassFilter<T> - Class in com.amazonaws.services.kinesis.connectors.impl

This class is a basic implementation of IFilter that returns true for all records.

AllPassFilter() - Constructor for class com.amazonaws.services.kinesis.connectors.impl.AllPassFilter

APP_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

AWS_CREDENTIALS_PROVIDER - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

B

BACKOFF_INTERVAL - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

BasicJsonTransformer<T,U> - Class in com.amazonaws.services.kinesis.connectors

This class implements the ITransformer interface and provides an implementation of the toClass() method for deserializing and serializing JSON strings.

BasicJsonTransformer(Class<T>) - Constructor for class com.amazonaws.services.kinesis.connectors.BasicJsonTransformer

BasicMemoryBuffer<T> - Class in com.amazonaws.services.kinesis.connectors.impl

This class is a basic implementation of the IBuffer interface.

BasicMemoryBuffer(KinesisConnectorConfiguration, List<T>) - Constructor for class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

BasicMemoryBuffer(KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

BATCH_RECORDS_IN_PUT_REQUEST - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

BUFFER_BYTE_SIZE_LIMIT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

BUFFER_MILLISECONDS_LIMIT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

BUFFER_RECORD_COUNT_LIMIT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

C

CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

clear() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

clear() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Clears the buffer

clear() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

CLOUDWATCH_BUFFER_TIME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

CLOUDWATCH_MAX_QUEUE_SIZE - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

CLOUDWATCH_NAMESPACE - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

com.amazonaws.services.kinesis.connectors - package com.amazonaws.services.kinesis.connectors

com.amazonaws.services.kinesis.connectors.dynamodb - package com.amazonaws.services.kinesis.connectors.dynamodb

com.amazonaws.services.kinesis.connectors.elasticsearch - package com.amazonaws.services.kinesis.connectors.elasticsearch

com.amazonaws.services.kinesis.connectors.impl - package com.amazonaws.services.kinesis.connectors.impl

com.amazonaws.services.kinesis.connectors.interfaces - package com.amazonaws.services.kinesis.connectors.interfaces

com.amazonaws.services.kinesis.connectors.redshift - package com.amazonaws.services.kinesis.connectors.redshift

com.amazonaws.services.kinesis.connectors.s3 - package com.amazonaws.services.kinesis.connectors.s3

CONNECTOR_DESTINATION - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

consumeRecord(T, int, String) - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

consumeRecord(T, int, String) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Stores the record in the buffer

consumeRecord(T, int, String) - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

createProcessor() - Method in class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessorFactory

createProcessor() - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessorFactory

D

DEFAULT_APP_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_BACKOFF_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_BATCH_RECORDS_IN_PUT_REQUEST - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_BUFFER_BYTE_SIZE_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_BUFFER_MILLISECONDS_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_BUFFER_RECORD_COUNT_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_CLOUDWATCH_BUFFER_TIME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_CLOUDWATCH_MAX_QUEUE_SIZE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_CLOUDWATCH_NAMESPACE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_CONNECTOR_DESTINATION - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_DYNAMODB_DATA_TABLE_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_DYNAMODB_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_CLUSTER_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_DEFAULT_INDEX_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_DEFAULT_TYPE_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_IGNORE_CLUSTER_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_NODE_SAMPLER_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_PING_TIMEOUT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_PORT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_TRANSPORT_SNIFF - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_ELASTICSEARCH_VERSION_NUMBER - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_FAILOVER_TIME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_IDLE_TIME_BETWEEN_READS - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_INITIAL_POSITION_IN_STREAM - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_KINESIS_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_KINESIS_INPUT_STREAM - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_KINESIS_OUTPUT_STREAM - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_KINESIS_STREAM_SHARD_COUNT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_MAX_RECORDS - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_MAXIMUM_PROCESS_RECORDS_WAIT_TIME_MS - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessor

Default maximum time to wait for the queue consumer to shutdown (finish ProcessRecords call).

DEFAULT_MAXIMUM_QUEUE_WAIT_TIME_MS - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessor

Default maximum time to block on the queue waiting for GetRecords result.

DEFAULT_PARENT_SHARD_POLL_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_COPY_MANDATORY - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_DATA_DELIMITER - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_DATA_TABLE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_FILE_KEY_COLUMN - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_FILE_TABLE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_PASSWORD - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_URL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REDSHIFT_USERNAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_REGION_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_RETRY_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_S3_BUCKET - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_S3_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_SHARD_SYNC_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DEFAULT_WORKER_ID - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DYNAMODB_DATA_TABLE_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

DYNAMODB_ENDPOINT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

dynamoDBClient - Variable in class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

DynamoDBEmitter - Class in com.amazonaws.services.kinesis.connectors.dynamodb

This class is used to store records from a stream in an Amazon DynamoDB table.

DynamoDBEmitter(KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

dynamoDBEndpoint - Variable in class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

dynamoDBTableName - Variable in class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

DynamoDBTransformer<T> - Interface in com.amazonaws.services.kinesis.connectors.dynamodb

This interface defines an ITransformer that has an output type of Map of attribute name (String) to AttributeValue so that the item can be put into Amazon DynamoDB.

E

ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_CLOUDFORMATION_STACK_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_CLUSTER_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_DEFAULT_INDEX_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_DEFAULT_TYPE_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_ENDPOINT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_IGNORE_CLUSTER_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_NODE_SAMPLER_INTERVAL - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_PING_TIMEOUT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_PORT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_TRANSPORT_SNIFF - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ELASTICSEARCH_VERSION_NUMBER - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

ElasticsearchEmitter - Class in com.amazonaws.services.kinesis.connectors.elasticsearch

ElasticsearchEmitter(KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchEmitter

ElasticsearchObject - Class in com.amazonaws.services.kinesis.connectors.elasticsearch

ElasticsearchObject defines the information needed by the ElasticsearchEmitter to properly index the record.

ElasticsearchObject(String, String, String) - Constructor for class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

ElasticsearchObject(String, String, String, String) - Constructor for class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

ElasticsearchTransformer<T> - Class in com.amazonaws.services.kinesis.connectors.elasticsearch

Transformer to use in the ElasticsearchPipeline.

ElasticsearchTransformer() - Constructor for class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchTransformer

emit(UnmodifiableBuffer<Map<String, AttributeValue>>) - Method in class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

emit(UnmodifiableBuffer<ElasticsearchObject>) - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchEmitter

Emits records to elasticsearch.

emit(UnmodifiableBuffer<T>) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IEmitter

Invoked when the buffer is full.

emit(UnmodifiableBuffer<byte[]>) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftBasicEmitter

emit(UnmodifiableBuffer<String>) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftManifestEmitter

emit(UnmodifiableBuffer<byte[]>) - Method in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

emit(UnmodifiableBuffer<byte[]>) - Method in class com.amazonaws.services.kinesis.connectors.s3.S3ManifestEmitter

equals(Object) - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

F

fail(List<Map<String, AttributeValue>>) - Method in class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

fail(List<ElasticsearchObject>) - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchEmitter

fail(List<T>) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IEmitter

This method defines how to handle a set of records that cannot successfully be emitted.

fail(List<byte[]>) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftBasicEmitter

fail(List<String>) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftManifestEmitter

fail(List<byte[]>) - Method in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

fail(List<byte[]>) - Method in class com.amazonaws.services.kinesis.connectors.s3.S3ManifestEmitter

FAILOVER_TIME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

fromClass(T) - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchTransformer

Creates an ElasticsearchObject with the information contained in the record.

fromClass(T) - Method in class com.amazonaws.services.kinesis.connectors.impl.JsonToByteArrayTransformer

fromClass(String) - Method in class com.amazonaws.services.kinesis.connectors.impl.StringToByteArrayTransformer

fromClass(String) - Method in class com.amazonaws.services.kinesis.connectors.impl.StringToStringTransformer

fromClass(T) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.ITransformerBase

Transform record from its original class to final output class.

fromClass(T) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftTransformer

G

generateCopyStatement(String) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftBasicEmitter

getBuffer(KinesisConnectorConfiguration) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IKinesisConnectorPipeline

Return an instance of the users implementation of IBuffer

getBytesToBuffer() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

getBytesToBuffer() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Get the byte size limit of data stored in the buffer before the records are flushed to the emitter

getBytesToBuffer() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

getCreate() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

getCurrentTimeMilliseconds() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

getEmitter(KinesisConnectorConfiguration) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IKinesisConnectorPipeline

Return an instance of the users implementation of IEmitter

getFilter(KinesisConnectorConfiguration) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IKinesisConnectorPipeline

Return an instance of the users implementation of IFilter.

getFirstSequenceNumber() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

getFirstSequenceNumber() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Get the sequence number of the first record stored in the buffer.

getFirstSequenceNumber() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

getId() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

getIndex() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

getKinesisConnectorRecordProcessorFactory() - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorExecutorBase

This method returns a KinesisConnectorRecordProcessorFactory that contains the appropriate IKinesisConnectorPipeline for the Amazon Kinesis Enabled Application

getLastSequenceNumber() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

getLastSequenceNumber() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Get the sequence number of the last record stored in the buffer.

getLastSequenceNumber() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

getMillisecondsToBuffer() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

getMillisecondsToBuffer() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Get the time limit in milliseconds before the records are flushed to the emitter

getMillisecondsToBuffer() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

getNumRecordsToBuffer() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

getNumRecordsToBuffer() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Get the record number limit of data stored in the buffer before the records are flushed to the emitter

getNumRecordsToBuffer() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

getRecords() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

getRecords() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Get the records stored in the buffer

getRecords() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

getS3FileName(String, String) - Method in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

getS3URI(String) - Method in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

getSource() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

getTransformer(KinesisConnectorConfiguration) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IKinesisConnectorPipeline

Return an instance of the users implementation of ITransformer.

getTtl() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

getType() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

getVersion() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

H

hashCode() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

I

IBuffer<T> - Interface in com.amazonaws.services.kinesis.connectors.interfaces

IBuffer defines a buffer used to store records streamed through Amazon Kinesis.

ICollectionTransformer<T,U> - Interface in com.amazonaws.services.kinesis.connectors.interfaces

ICollectionTransformer is used to transform data from an Amazon Kinesis Record (byte array) to a collection of the data model class (T) for processing in the application and from the data model class to the output type (U) for the emitter.

IDLE_TIME_BETWEEN_READS - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

IEmitter<T> - Interface in com.amazonaws.services.kinesis.connectors.interfaces

IEmitter takes a full buffer and processes the stored records.

IFilter<T> - Interface in com.amazonaws.services.kinesis.connectors.interfaces

The IFilter is associated with an IBuffer.

IKinesisConnectorPipeline<T,U> - Interface in com.amazonaws.services.kinesis.connectors.interfaces

This interface is used by the KinesisConnectorRecordProcessorFactory to obtain instances of the user's implemented classes.

INITIAL_POSITION_IN_STREAM - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

initialize(String) - Method in class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessor

initialize(KinesisConnectorConfiguration) - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorExecutorBase

Initialize the Amazon Kinesis Client Library configuration and worker

initialize(KinesisConnectorConfiguration, IMetricsFactory) - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorExecutorBase

Initialize the Amazon Kinesis Client Library configuration and worker with metrics factory

initialize(String) - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessor

inputClass - Variable in class com.amazonaws.services.kinesis.connectors.BasicJsonTransformer

ITransformer<T,U> - Interface in com.amazonaws.services.kinesis.connectors.interfaces

ITransformer is used to transform data from a Record (byte array) to the data model class (T) for processing in the application and from the data model class to the output type (U) for the emitter.

ITransformerBase<T,U> - Interface in com.amazonaws.services.kinesis.connectors.interfaces

Base transformer class to provide backwards compatibility with ITransformer while supporting the ICollectionTransformer.

J

JsonToByteArrayTransformer<T> - Class in com.amazonaws.services.kinesis.connectors.impl

The JsonToByteArrayTransformer defines a BasicJsonTransformer with byte array for its output type.

JsonToByteArrayTransformer(Class<T>) - Constructor for class com.amazonaws.services.kinesis.connectors.impl.JsonToByteArrayTransformer

K

keepRecord(T) - Method in class com.amazonaws.services.kinesis.connectors.impl.AllPassFilter

keepRecord(T) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IFilter

A method enabling the buffer to filter records.

KINESIS_CONNECTOR_USER_AGENT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

KINESIS_ENDPOINT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

KINESIS_INPUT_STREAM - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

KINESIS_INPUT_STREAM_SHARD_COUNT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

KINESIS_OUTPUT_STREAM - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

KINESIS_OUTPUT_STREAM_SHARD_COUNT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

KinesisClientLibraryPipelinedRecordProcessor - Class in com.amazonaws.services.kinesis.connectors

Wraps an IRecordProcessor to pipeline fetching and processing records.

KinesisClientLibraryPipelinedRecordProcessor(IRecordProcessor, int) - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessor

Constructor.

KinesisClientLibraryPipelinedRecordProcessor(IRecordProcessor, int, Long, Long) - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessor

Constructor.

KinesisClientLibraryPipelinedRecordProcessorFactory - Class in com.amazonaws.services.kinesis.connectors

Wraps an IRecordProcessorFactory to decouple fetching records and processing records in the created IRecordProcessor.

KinesisClientLibraryPipelinedRecordProcessorFactory(IRecordProcessorFactory, int) - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessorFactory

Constructor to wrap an IRecordProcessorFactory as a pipelined record processor factory.

KinesisClientLibraryPipelinedRecordProcessorFactory(IRecordProcessorFactory, int, Long, Long) - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessorFactory

Constructor to wrap an IRecordProcessorFactory as a pipelined record processor factory.

KinesisConnectorConfiguration - Class in com.amazonaws.services.kinesis.connectors

This class contains constants used to configure AWS Services in Amazon Kinesis Connectors.

KinesisConnectorConfiguration(Properties, AWSCredentialsProvider) - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

Configure the connector application with any set of properties that are unique to the application.

KinesisConnectorExecutorBase<T,U> - Class in com.amazonaws.services.kinesis.connectors

KinesisConnectorExecutorBase() - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisConnectorExecutorBase

KinesisConnectorRecordProcessor<T,U> - Class in com.amazonaws.services.kinesis.connectors

This is the base class for any KinesisConnector.

KinesisConnectorRecordProcessor(IBuffer<T>, IFilter<T>, IEmitter<U>, ITransformerBase<T, U>, KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessor

KinesisConnectorRecordProcessorFactory<T,U> - Class in com.amazonaws.services.kinesis.connectors

This class is used to generate KinesisConnectorRecordProcessors that operate using the user's implemented classes.

KinesisConnectorRecordProcessorFactory(IKinesisConnectorPipeline<T, U>, KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessorFactory

M

MAX_RECORDS - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

P

PARENT_SHARD_POLL_INTERVAL - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

processRecords(List<Record>, IRecordProcessorCheckpointer) - Method in class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessor

processRecords(List<Record>, IRecordProcessorCheckpointer) - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessor

PROP_APP_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_BACKOFF_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_BATCH_RECORDS_IN_PUT_REQUEST - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_BUFFER_BYTE_SIZE_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_BUFFER_MILLISECONDS_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_BUFFER_RECORD_COUNT_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_CLOUDWATCH_BUFFER_TIME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_CLOUDWATCH_MAX_QUEUE_SIZE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_CLOUDWATCH_NAMESPACE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_CONNECTOR_DESTINATION - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_DYNAMODB_DATA_TABLE_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_DYNAMODB_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_INSTANCE_TYPE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_CLOUDFORMATION_CLUSTER_SIZE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_CLOUDFORMATION_KEY_PAIR_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_CLOUDFORMATION_SSH_LOCATION - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_CLOUDFORMATION_STACK_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_CLOUDFORMATION_TEMPLATE_URL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_CLUSTER_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_DEFAULT_INDEX_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_DEFAULT_TYPE_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_IGNORE_CLUSTER_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_NODE_SAMPLER_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_PING_TIMEOUT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_PORT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_TRANSPORT_SNIFF - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_ELASTICSEARCH_VERSION_NUMBER - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_FAILOVER_TIME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_IDLE_TIME_BETWEEN_READS - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_INITIAL_POSITION_IN_STREAM - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_KINESIS_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_KINESIS_INPUT_STREAM - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_KINESIS_INPUT_STREAM_SHARD_COUNT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_KINESIS_OUTPUT_STREAM - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_KINESIS_OUTPUT_STREAM_SHARD_COUNT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_MAX_RECORDS - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_PARENT_SHARD_POLL_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_COPY_MANDATORY - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_DATA_DELIMITER - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_DATA_TABLE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_FILE_KEY_COLUMN - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_FILE_TABLE - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_PASSWORD - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_URL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REDSHIFT_USERNAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_REGION_NAME - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_RETRY_LIMIT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_S3_BUCKET - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_S3_ENDPOINT - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_SHARD_SYNC_INTERVAL - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

PROP_WORKER_ID - Static variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

R

REDSHIFT_COPY_MANDATORY - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_DATA_DELIMITER - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_DATA_TABLE - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_ENDPOINT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_FILE_KEY_COLUMN - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_FILE_TABLE - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_PASSWORD - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_URL - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

REDSHIFT_USERNAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

RedshiftBasicEmitter - Class in com.amazonaws.services.kinesis.connectors.redshift

This class is an implementation of IEmitter that emits records into Amazon Redshift one by one.

RedshiftBasicEmitter(KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.redshift.RedshiftBasicEmitter

redshiftCopy(Connection, String) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftManifestEmitter

Executes a, Amazon Redshift copy from Amazon S3 using a Manifest file with a command in the format: COPY dataTable FROM 's3://s3Bucket/manifestFile' CREDENTIALS 'aws_access_key_id=accessKey;aws_secret_access_key=secretKey' DELIMITER dataDelimiter MANIFEST;

RedshiftManifestEmitter - Class in com.amazonaws.services.kinesis.connectors.redshift

This implementation of IEmitter collects filenames from an Amazon Kinesis stream that has been started by a S3ManifestEmitter.

RedshiftManifestEmitter(KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.redshift.RedshiftManifestEmitter

RedshiftTransformer<T> - Class in com.amazonaws.services.kinesis.connectors.redshift

This class is an implementation of the ITransformer interface and an extension of the BasicJsonTransformer class.

RedshiftTransformer(Class<T>) - Constructor for class com.amazonaws.services.kinesis.connectors.redshift.RedshiftTransformer

REGION_NAME - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

RETRY_LIMIT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

run() - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorExecutorBase

S

S3_BUCKET - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

S3_ENDPOINT - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

s3Bucket - Variable in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

s3client - Variable in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

S3Emitter - Class in com.amazonaws.services.kinesis.connectors.s3

This implementation of IEmitter is used to store files from an Amazon Kinesis stream in S3.

S3Emitter(KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

s3Endpoint - Variable in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

S3ManifestEmitter - Class in com.amazonaws.services.kinesis.connectors.s3

This implementaion of IEmitter inserts records into Amazon S3 and emits filenames into a separate Amazon Kinesis stream.

S3ManifestEmitter(KinesisConnectorConfiguration) - Constructor for class com.amazonaws.services.kinesis.connectors.s3.S3ManifestEmitter

setCreate(boolean) - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

setTtl(long) - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

setVersion(long) - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

SHARD_SYNC_INTERVAL - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

shouldFlush() - Method in class com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer

By default, we flush once we have exceeded the number of messages or maximum bytes to buffer.

shouldFlush() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IBuffer

Returns true if the buffer is full and stored records should be sent to the emitter

shouldFlush() - Method in class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

shutdown() - Method in class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

shutdown() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchEmitter

shutdown() - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.IEmitter

This method is called when the KinesisConnectorRecordProcessor is shutdown.

shutdown(IRecordProcessorCheckpointer, ShutdownReason) - Method in class com.amazonaws.services.kinesis.connectors.KinesisClientLibraryPipelinedRecordProcessor

shutdown(IRecordProcessorCheckpointer, ShutdownReason) - Method in class com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessor

shutdown() - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftBasicEmitter

shutdown() - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftManifestEmitter

shutdown() - Method in class com.amazonaws.services.kinesis.connectors.s3.S3Emitter

shutdown() - Method in class com.amazonaws.services.kinesis.connectors.s3.S3ManifestEmitter

StringToByteArrayTransformer - Class in com.amazonaws.services.kinesis.connectors.impl

This class is an implementation of the ITransformer to transform between raw Amazon Kinesis records and strings.

StringToByteArrayTransformer() - Constructor for class com.amazonaws.services.kinesis.connectors.impl.StringToByteArrayTransformer

StringToStringTransformer - Class in com.amazonaws.services.kinesis.connectors.impl

This class is an implementation of the ITransformer to transform between raw Amazon Kinesis records and strings.

StringToStringTransformer() - Constructor for class com.amazonaws.services.kinesis.connectors.impl.StringToStringTransformer

T

toClass(Record) - Method in class com.amazonaws.services.kinesis.connectors.BasicJsonTransformer

toClass(Record) - Method in class com.amazonaws.services.kinesis.connectors.impl.StringToByteArrayTransformer

toClass(Record) - Method in class com.amazonaws.services.kinesis.connectors.impl.StringToStringTransformer

toClass(Record) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.ICollectionTransformer

Transform record into a collection of object of their original class.

toClass(Record) - Method in interface com.amazonaws.services.kinesis.connectors.interfaces.ITransformer

Transform record into an object of its original class.

toDelimitedString(T) - Method in class com.amazonaws.services.kinesis.connectors.redshift.RedshiftTransformer

This method requires implementing classes to output a string representation of the data model that is compatible with Amazon Redshift.

toString() - Method in class com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchObject

U

uniqueItems(List<Map<String, AttributeValue>>) - Method in class com.amazonaws.services.kinesis.connectors.dynamodb.DynamoDBEmitter

This helper method is used to dedupe a list of items.

UnmodifiableBuffer<T> - Class in com.amazonaws.services.kinesis.connectors

This class is a wrapper on an IBuffer that limits the functionality of the buffer.

UnmodifiableBuffer(IBuffer<T>) - Constructor for class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

UnmodifiableBuffer(IBuffer<?>, List<T>) - Constructor for class com.amazonaws.services.kinesis.connectors.UnmodifiableBuffer

W

worker - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorExecutorBase

WORKER_ID - Variable in class com.amazonaws.services.kinesis.connectors.KinesisConnectorConfiguration

A B C D E F G H I J K M P R S T U W