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

A

accept() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.DataFetcherResult
Accepts the result, and advances the shard iterator.
AccumulateByNameMetricsScope - Class in com.amazonaws.services.kinesis.metrics.impl
This is a MetricScope with a KeyType of String.
AccumulateByNameMetricsScope() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.AccumulateByNameMetricsScope
 
AccumulatingMetricsScope<KeyType> - Class in com.amazonaws.services.kinesis.metrics.impl
An IMetricsScope that accumulates data from multiple calls to addData with the same name parameter.
AccumulatingMetricsScope() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.AccumulatingMetricsScope
 
ACTION - Static variable in class com.amazonaws.services.kinesis.multilang.messages.CheckpointMessage
The name used for the action field in Message.
ACTION - Static variable in class com.amazonaws.services.kinesis.multilang.messages.InitializeMessage
The name used for the action field in Message.
ACTION - Static variable in class com.amazonaws.services.kinesis.multilang.messages.JsonFriendlyRecord
 
ACTION - Static variable in class com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage
The name used for the action field in Message.
ACTION - Static variable in class com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage
The name used for the action field in Message.
ACTION - Static variable in class com.amazonaws.services.kinesis.multilang.messages.ShutdownRequestedMessage
The name used for the action field in Message.
ACTION - Static variable in class com.amazonaws.services.kinesis.multilang.messages.StatusMessage
The name used for the action field in Message.
addAllExplicitHashKeyTable(Iterable<String>) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
addAllPartitionKeyTable(Iterable<String>) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
addAllRecords(Iterable<? extends Messages.Record>) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
addAllTags(Iterable<? extends Messages.Tag>) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
addData(String, double, StandardUnit) - Method in class com.amazonaws.services.kinesis.metrics.impl.AccumulatingMetricsScope
 
addData(String, double, StandardUnit, MetricsLevel) - Method in class com.amazonaws.services.kinesis.metrics.impl.AccumulatingMetricsScope
 
addData(KeyType, String, double, StandardUnit) - Method in class com.amazonaws.services.kinesis.metrics.impl.AccumulatingMetricsScope
Adds data points to an IMetricsScope.
addData(String, double, StandardUnit) - Method in class com.amazonaws.services.kinesis.metrics.impl.EndingMetricsScope
 
addData(String, double, StandardUnit, MetricsLevel) - Method in class com.amazonaws.services.kinesis.metrics.impl.EndingMetricsScope
 
addData(String, double, StandardUnit) - Method in class com.amazonaws.services.kinesis.metrics.impl.FilteringMetricsScope
Adds the data to the metrics scope at lowest metrics level.
addData(String, double, StandardUnit, MetricsLevel) - Method in class com.amazonaws.services.kinesis.metrics.impl.FilteringMetricsScope
Adds the data to the metrics scope if the given level is equal to above the enabled metrics level.
addData(String, double, StandardUnit) - Method in class com.amazonaws.services.kinesis.metrics.impl.NullMetricsScope
 
addData(String, double, StandardUnit, MetricsLevel) - Method in class com.amazonaws.services.kinesis.metrics.impl.NullMetricsScope
 
addData(String, double, StandardUnit) - Method in class com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingScope
Adds a data point to this IMetricsScope.
addData(String, double, StandardUnit, MetricsLevel) - Method in class com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingScope
Adds a data point to this IMetricsScope if given metrics level is enabled.
addData(String, double, StandardUnit) - Method in interface com.amazonaws.services.kinesis.metrics.interfaces.IMetricsScope
Adds a data point to this IMetricsScope.
addData(String, double, StandardUnit, MetricsLevel) - Method in interface com.amazonaws.services.kinesis.metrics.interfaces.IMetricsScope
Adds a data point to this IMetricsScope if given metrics level is enabled.
addDimension(String, String) - Method in class com.amazonaws.services.kinesis.metrics.impl.DimensionTrackingMetricsScope
 
addDimension(String, String) - Method in class com.amazonaws.services.kinesis.metrics.impl.EndingMetricsScope
 
addDimension(String, String) - Method in class com.amazonaws.services.kinesis.metrics.impl.FilteringMetricsScope
Adds given dimension with value if allowed dimensions list contains this dimension's name.
addDimension(String, String) - Method in class com.amazonaws.services.kinesis.metrics.impl.NullMetricsScope
 
addDimension(String, String) - Method in class com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingScope
Adds a dimension that applies to all metrics in this IMetricsScope.
addDimension(String, String) - Method in interface com.amazonaws.services.kinesis.metrics.interfaces.IMetricsScope
Adds a dimension that applies to all metrics in this IMetricsScope.
addExplicitHashKeyTable(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
addExplicitHashKeyTableBytes(ByteString) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
addLatency(long, MetricsLevel) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
addLatency(String, long, MetricsLevel) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
addLatencyPerShard(String, String, long, MetricsLevel) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
addLeasesToRenew(Collection<T>) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
Adds leases to this LeaseRenewer's set of currently held leases.
addLeasesToRenew(Collection<T>) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
Adds leases to this LeaseRenewer's set of currently held leases.
addPartitionKeyTable(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
addPartitionKeyTableBytes(ByteString) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
addRecords(Messages.Record) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
addRecords(int, Messages.Record) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
addRecords(Messages.Record.Builder) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
addRecords(int, Messages.Record.Builder) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
addRecordsBuilder() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
addRecordsBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
addSuccessAndLatency(long, boolean, MetricsLevel) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
addSuccessAndLatency(String, long, boolean, MetricsLevel) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
addSuccessAndLatencyPerShard(String, String, long, boolean, MetricsLevel) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
addTags(Messages.Tag) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
addTags(int, Messages.Tag) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
addTags(Messages.Tag.Builder) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
addTags(int, Messages.Tag.Builder) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
addTagsBuilder() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
addTagsBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
AsynchronousGetRecordsRetrievalStrategy - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
AsynchronousGetRecordsRetrievalStrategy(KinesisDataFetcher, int, int, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy
 
AsynchronousGetRecordsRetrievalStrategy(KinesisDataFetcher, ExecutorService, int, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy
 
AT_TIMESTAMP - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
Special value for AT_TIMESTAMP.

B

BlockedOnParentShardException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions.internal
Used internally in the Amazon Kinesis Client Library.
BlockedOnParentShardException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.internal.BlockedOnParentShardException
Constructor.
BlockedOnParentShardException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.internal.BlockedOnParentShardException
Constructor.
BlockingGetRecordsCache - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
This is the BlockingGetRecordsCache class.
BlockingGetRecordsCache(int, GetRecordsRetrievalStrategy) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.BlockingGetRecordsCache
 
build() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker.Builder
Build the Worker instance.
build() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
build() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
build() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
buildConsumer(ShardInfo, IRecordProcessorFactory) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
 
Builder() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker.Builder
 
buildPartial() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
buildPartial() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
buildPartial() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 

C

CACHE_MAX_ALLOWED_AGE - Static variable in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
 
CACHE_MISS_WARNING_MODULUS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
 
call() - Method in class com.amazonaws.services.kinesis.multilang.MultiLangDaemon
 
canTransitionTo(ShutdownReason) - Method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownReason
Indicates whether the given reason can override the current reason.
checkAndCreateLeasesForNewShards(IKinesisProxy, ILeaseManager<KinesisClientLease>, InitialPositionInStreamExtended, boolean, boolean) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncer
 
checkpoint() - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IPreparedCheckpointer
This method will record a pending checkpoint.
checkpoint() - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will checkpoint the progress at the last data record that was delivered to the record processor.
checkpoint(Record) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will checkpoint the progress at the provided record.
checkpoint(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will checkpoint the progress at the provided sequenceNumber.
checkpoint(String, long) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will checkpoint the progress at the provided sequenceNumber and subSequenceNumber, the latter for aggregated records produced with the Producer Library.
Checkpoint - Class in com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint
A class encapsulating the 2 pieces of state stored in a checkpoint.
Checkpoint(ExtendedSequenceNumber, ExtendedSequenceNumber) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint.Checkpoint
Constructor.
checkpoint() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.DoesNothingPreparedCheckpointer
This method will record a pending checkpoint.
checkpoint() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PreparedCheckpointer
This method will record a pending checkpoint.
CheckpointMessage - Class in com.amazonaws.services.kinesis.multilang.messages
A checkpoint message is sent by the client's subprocess to indicate to the kcl processor that it should attempt to checkpoint.
CheckpointMessage() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.CheckpointMessage
Default constructor.
CheckpointMessage(String, Long, Throwable) - Constructor for class com.amazonaws.services.kinesis.multilang.messages.CheckpointMessage
Convenience constructor.
clazz - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
clear() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
clear() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
clear() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
clearCurrentlyHeldLeases() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
Clears this LeaseRenewer's set of currently held leases.
clearCurrentlyHeldLeases() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
Clears this LeaseRenewer's set of currently held leases.
clearData() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required bytes data = 3;
clearExplicitHashKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
optional uint64 explicit_hash_key_index = 2;
clearExplicitHashKeyTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
clearKey() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
required string key = 1;
clearPartitionKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required uint64 partition_key_index = 1;
clearPartitionKeyTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
clearRecords() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
clearTags() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
clearValue() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
optional string value = 2;
clone() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
clone() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
clone() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
com.amazonaws.services.kinesis.clientlibrary.config - package com.amazonaws.services.kinesis.clientlibrary.config
 
com.amazonaws.services.kinesis.clientlibrary.exceptions - package com.amazonaws.services.kinesis.clientlibrary.exceptions
 
com.amazonaws.services.kinesis.clientlibrary.exceptions.internal - package com.amazonaws.services.kinesis.clientlibrary.exceptions.internal
 
com.amazonaws.services.kinesis.clientlibrary.interfaces - package com.amazonaws.services.kinesis.clientlibrary.interfaces
 
com.amazonaws.services.kinesis.clientlibrary.interfaces.v2 - package com.amazonaws.services.kinesis.clientlibrary.interfaces.v2
 
com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint - package com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint
 
com.amazonaws.services.kinesis.clientlibrary.lib.worker - package com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
com.amazonaws.services.kinesis.clientlibrary.proxies - package com.amazonaws.services.kinesis.clientlibrary.proxies
 
com.amazonaws.services.kinesis.clientlibrary.types - package com.amazonaws.services.kinesis.clientlibrary.types
 
com.amazonaws.services.kinesis.clientlibrary.utils - package com.amazonaws.services.kinesis.clientlibrary.utils
 
com.amazonaws.services.kinesis.leases.exceptions - package com.amazonaws.services.kinesis.leases.exceptions
 
com.amazonaws.services.kinesis.leases.impl - package com.amazonaws.services.kinesis.leases.impl
 
com.amazonaws.services.kinesis.leases.interfaces - package com.amazonaws.services.kinesis.leases.interfaces
 
com.amazonaws.services.kinesis.leases.util - package com.amazonaws.services.kinesis.leases.util
 
com.amazonaws.services.kinesis.metrics.impl - package com.amazonaws.services.kinesis.metrics.impl
 
com.amazonaws.services.kinesis.metrics.interfaces - package com.amazonaws.services.kinesis.metrics.interfaces
 
com.amazonaws.services.kinesis.multilang - package com.amazonaws.services.kinesis.multilang
This package provides a KCL application which implements the multi language protocol.
com.amazonaws.services.kinesis.multilang.messages - package com.amazonaws.services.kinesis.multilang.messages
 
compareTo(ExtendedSequenceNumber) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
Compares this with another ExtendedSequenceNumber using these rules.
consistentReads - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
 
convertAndRethrowExceptions(String, String, AmazonClientException) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
 
copy() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
Returns a deep copy of this object.
copy() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
Returns a deep copy of this object.
createAttributeValue(Collection<String>) - Static method in class com.amazonaws.services.kinesis.leases.util.DynamoUtils
 
createAttributeValue(String) - Static method in class com.amazonaws.services.kinesis.leases.util.DynamoUtils
 
createAttributeValue(Long) - Static method in class com.amazonaws.services.kinesis.leases.util.DynamoUtils
 
createGracefulShutdownCallable() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Creates a callable that will execute the graceful shutdown process.
createLeaseIfNotExists(T) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Create a new lease.
createLeaseIfNotExists(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Create a new lease.
createLeaseTableIfNotExists(Long, Long) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Creates the table that will store leases.
createLeaseTableIfNotExists(Long, Long) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Creates the table that will store leases.
createMetrics() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
 
createMetrics() - Method in class com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory
 
createMetrics() - Method in class com.amazonaws.services.kinesis.metrics.impl.LogMetricsFactory
 
createMetrics() - Method in class com.amazonaws.services.kinesis.metrics.impl.NullMetricsFactory
 
createMetrics() - Method in class com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingFactory
createMetrics() - Method in interface com.amazonaws.services.kinesis.metrics.interfaces.IMetricsFactory
 
createProcessor() - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory
Returns a record processor to be used for processing data records for a (assigned) shard.
createProcessor() - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessorFactory
Returns a record processor to be used for processing data records for a (assigned) shard.
createProcessor() - Method in class com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessorFactory
 
createRecordsFetcher(GetRecordsRetrievalStrategy, String, IMetricsFactory, int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory
Returns a GetRecordsCache to be used for retrieving records for a given shard.
createRecordsFetcher(GetRecordsRetrievalStrategy, String, IMetricsFactory, int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory
 
CWMetricKey - Class in com.amazonaws.services.kinesis.metrics.impl
 
CWMetricKey(MetricDatum) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWMetricKey
 
CWMetricsFactory - Class in com.amazonaws.services.kinesis.metrics.impl
An IMetricsFactory that creates IMetricsScopes that output themselves via CloudWatch.
CWMetricsFactory(AWSCredentialsProvider, String, long, int) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
Constructor.
CWMetricsFactory(AWSCredentialsProvider, ClientConfiguration, String, long, int) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
Constructor.
CWMetricsFactory(AmazonCloudWatch, String, long, int) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
Constructor.
CWMetricsFactory(AmazonCloudWatch, String, long, int, MetricsLevel, Set<String>) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
Constructor.
CWMetricsScope - Class in com.amazonaws.services.kinesis.metrics.impl
Metrics scope for CloudWatch metrics.
CWMetricsScope(CWPublisherRunnable<CWMetricKey>, MetricsLevel, Set<String>) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWMetricsScope
Creates a CloudWatch metrics scope with given metrics level and enabled dimensions.
CWPublisherRunnable<KeyType> - Class in com.amazonaws.services.kinesis.metrics.impl
A CWPublisherRunnable contains the logic of when to publish metrics.
CWPublisherRunnable(ICWMetricsPublisher<KeyType>, long, int, int) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
Constructor.
CWPublisherRunnable(ICWMetricsPublisher<KeyType>, long, int, int, int) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
 

D

data - Variable in class com.amazonaws.services.kinesis.metrics.impl.AccumulatingMetricsScope
 
DATA_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
DataFetcherResult - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Represents the result from the DataFetcher, and allows the receiver to accept a result
DataFetchingStrategy - Enum in com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
datum - Variable in class com.amazonaws.services.kinesis.metrics.impl.MetricDatumWithKey
 
deaggregate(List<Record>) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
This method deaggregates the given list of Amazon Kinesis records into a list of KPL user records.
deaggregate(List<Record>, BigInteger, BigInteger) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
This method deaggregates the given list of Amazon Kinesis records into a list of KPL user records.
DEFAULT_CLEANUP_LEASES_UPON_SHARDS_COMPLETION - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Cleanup leases upon shards completion (don't wait until they expire in Kinesis).
DEFAULT_DONT_CALL_PROCESS_RECORDS_FOR_EMPTY_RECORD_LIST - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Don't call processRecords() on the record processor for empty record lists.
DEFAULT_FAILOVER_TIME_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Fail over time in milliseconds.
DEFAULT_IDLETIME_BETWEEN_READS_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The default value for how long the ShardConsumer should sleep if no records are returned from the call to AmazonKinesis.getRecords(com.amazonaws.services.kinesis.model.GetRecordsRequest).
DEFAULT_INITIAL_LEASE_TABLE_READ_CAPACITY - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The Amazon DynamoDB table used for tracking leases will be provisioned with this read capacity.
DEFAULT_INITIAL_LEASE_TABLE_WRITE_CAPACITY - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The Amazon DynamoDB table used for tracking leases will be provisioned with this write capacity.
DEFAULT_INITIAL_POSITION_IN_STREAM - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The location in the shard from which the KinesisClientLibrary will start fetching records from when the application starts for the first time and there is no checkpoint for the shard.
DEFAULT_LIST_SHARDS_BACKOFF_TIME_IN_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The sleep time between two listShards calls from the proxy when throttled.
DEFAULT_MAX_LEASE_RENEWAL_THREADS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The size of the thread pool to create for the lease renewer to use.
DEFAULT_MAX_LEASES_FOR_WORKER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The max number of leases (shards) this worker should process.
DEFAULT_MAX_LEASES_TO_STEAL_AT_ONE_TIME - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Max leases to steal from another worker at one time (for load balancing).
DEFAULT_MAX_LIST_SHARDS_RETRY_ATTEMPTS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The number of times the Proxy will retry listShards call when throttled.
DEFAULT_MAX_RECORDS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Max records to fetch from Kinesis in a single GetRecords call.
DEFAULT_METRICS_BUFFER_TIME_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Buffer metrics for at most this long before publishing to CloudWatch.
DEFAULT_METRICS_ENABLED_DIMENSIONS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Allowed dimensions for CloudWatch metrics.
DEFAULT_METRICS_ENABLED_DIMENSIONS - Static variable in class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
Default metrics dimensions.
DEFAULT_METRICS_LEVEL - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Metrics level for which to enable CloudWatch metrics.
DEFAULT_METRICS_LEVEL - Static variable in class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
Default metrics level to enable.
DEFAULT_METRICS_MAX_QUEUE_SIZE - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Buffer at most this many metrics before publishing to CloudWatch.
DEFAULT_PARENT_SHARD_POLL_INTERVAL_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Interval in milliseconds between polling to check for parent shard completion.
DEFAULT_SHARD_PRIORITIZATION - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Default Shard prioritization strategy.
DEFAULT_SHARD_SYNC_INTERVAL_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Shard sync interval in milliseconds - e.g.
DEFAULT_SHARD_SYNC_STRATEGY_TYPE - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Default ShardSyncStrategy to be used for discovering new shards in the Stream.
DEFAULT_SHUTDOWN_GRACE_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The amount of milliseconds to wait before graceful shutdown forcefully terminates.
DEFAULT_SKIP_SHARD_SYNC_AT_STARTUP_IF_LEASES_EXIST - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
The Worker will skip shard sync during initialization if there are one or more leases in the lease table.
DEFAULT_TASK_BACKOFF_TIME_MILLIS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Backoff time in milliseconds for Amazon Kinesis Client Library tasks (in the event of failures).
DEFAULT_VALIDATE_SEQUENCE_NUMBER_BEFORE_CHECKPOINTING - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
KCL will validate client provided sequence numbers with a call to Amazon Kinesis before checkpointing for calls to RecordProcessorCheckpointer.checkpoint(String) by default.
DefaultCWMetricsPublisher - Class in com.amazonaws.services.kinesis.metrics.impl
Default implementation for publishing metrics to CloudWatch.
DefaultCWMetricsPublisher(AmazonCloudWatch, String) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.DefaultCWMetricsPublisher
 
deleteAll() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Delete all leases from DynamoDB.
deleteAll() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Delete all leases from DynamoDB.
deleteLease(T) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Delete the given lease from DynamoDB.
deleteLease(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Delete the given lease from DynamoDB.
DependencyException - Exception in com.amazonaws.services.kinesis.leases.exceptions
Indicates that a lease operation has failed because a dependency of the leasing system has failed.
DependencyException(Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.DependencyException
 
DependencyException(String, Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.DependencyException
 
DimensionTrackingMetricsScope - Class in com.amazonaws.services.kinesis.metrics.impl
DimensionTrackingMetricsScope is where we provide functionality for dimensions.
DimensionTrackingMetricsScope() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.DimensionTrackingMetricsScope
 
DoesNothingPreparedCheckpointer - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
A special IPreparedCheckpointer that does nothing, which can be used when preparing a checkpoint at the current checkpoint sequence number where it is never necessary to do another checkpoint.
DoesNothingPreparedCheckpointer(ExtendedSequenceNumber) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.DoesNothingPreparedCheckpointer
Constructor.
drain(int) - Method in class com.amazonaws.services.kinesis.metrics.impl.MetricAccumulatingQueue
 
dropLease(T) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Requests that renewals for the given lease are stopped.
dropLease(T) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
Stops the lease renewer from continunig to maintain the given lease.
dropLease(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
Stops the lease renewer from continunig to maintain the given lease.
dynamoDBClient - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
 
DynamoUtils - Class in com.amazonaws.services.kinesis.leases.util
Static utility functions used by our LeaseSerializers.
DynamoUtils() - Constructor for class com.amazonaws.services.kinesis.leases.util.DynamoUtils
 

E

end() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWMetricsScope
Once we call this method, all MetricDatums added to the scope will be enqueued to the publisher runnable.
end() - Method in class com.amazonaws.services.kinesis.metrics.impl.EndingMetricsScope
 
end() - Method in class com.amazonaws.services.kinesis.metrics.impl.LogMetricsScope
 
end() - Method in class com.amazonaws.services.kinesis.metrics.impl.NullMetricsScope
 
end() - Method in class com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingScope
Flushes the data from this IMetricsScope and causes future calls to addData and addDimension to fail.
end() - Method in interface com.amazonaws.services.kinesis.metrics.interfaces.IMetricsScope
Flushes the data from this IMetricsScope and causes future calls to addData and addDimension to fail.
EndingMetricsScope - Class in com.amazonaws.services.kinesis.metrics.impl
 
EndingMetricsScope() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.EndingMetricsScope
 
endScope() - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
enqueue(Collection<MetricDatumWithKey<KeyType>>) - Method in class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
Enqueues metric data for publication.
equals(Object) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
This method assumes parentShardIds is ordered.
equals(Object) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
 
equals(Object) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
equals(Object) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
equals(Object) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
equals(Object) - Method in class com.amazonaws.services.kinesis.metrics.impl.CWMetricKey
 
equals(Object) - Method in class com.amazonaws.services.kinesis.metrics.impl.MetricDatumWithKey
 
evictLease(T) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Evict the current owner of lease by setting owner to null.
evictLease(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Evict the current owner of lease by setting owner to null.
EXPLICIT_HASH_KEY_INDEX_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
EXPLICIT_HASH_KEY_TABLE_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
ExtendedSequenceNumber - Class in com.amazonaws.services.kinesis.clientlibrary.types
Represents a two-part sequence number for records aggregated by the Kinesis Producer Library.
ExtendedSequenceNumber(String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
Construct an ExtendedSequenceNumber.
ExtendedSequenceNumber(String, Long) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
Construct an ExtendedSequenceNumber.

F

FilteringMetricsScope - Class in com.amazonaws.services.kinesis.metrics.impl
An IMetricsScope that filters FilteringMetricsScope.addData(java.lang.String, double, com.amazonaws.services.cloudwatch.model.StandardUnit) calls based on the provided metrics level.
FilteringMetricsScope() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.FilteringMetricsScope
Creates a metrics scope that allows all metrics data and dimensions.
FilteringMetricsScope(MetricsLevel, Set<String>) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.FilteringMetricsScope
Creates a metrics scope that drops data with level below the given enabled level and only allows dimensions that are part of the given enabled dimensions list.
fromDynamoRecord(Map<String, AttributeValue>) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
fromDynamoRecord(Map<String, AttributeValue>) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
fromDynamoRecord(Map<String, AttributeValue>) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
Construct a Lease object out of a DynamoDB record.
fromName(String) - Static method in enum com.amazonaws.services.kinesis.metrics.interfaces.MetricsLevel
Returns metrics level associated with the given name.

G

GenericLeaseSelector<T extends Lease> - Class in com.amazonaws.services.kinesis.leases.impl
GenericLeaseSelector abstracts away the lease selection logic from the application code that's using leasing.
GenericLeaseSelector() - Constructor for class com.amazonaws.services.kinesis.leases.impl.GenericLeaseSelector
 
get(String, int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
Get records from stream.
get(String, int) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Get records from stream.
get(String, int) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Get records from stream.
getAction() - Method in class com.amazonaws.services.kinesis.multilang.messages.JsonFriendlyRecord
 
getAllShardIds() - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
Fetch the shardIds of all shards in the stream.
getAllShardIds() - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Fetch the shardIds of all shards in the stream.
getAllShardIds() - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Fetch the shardIds of all shards in the stream.
getApplicationName() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getApplicationName() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
 
getAssignments() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
getAttributeDefinitions() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getAttributeDefinitions() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getAttributeDefinitions() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getCheckpoint(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.ICheckpoint
Get the current checkpoint stored for the specified shard.
getCheckpoint() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
getCheckpoint(String) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseManager
Gets the current checkpoint of the shard.
getCheckpoint(String) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.IKinesisClientLeaseManager
Gets the current checkpoint of the shard.
getCheckpointer() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
Get Checkpointer.
getCheckpointer() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput
Get Checkpointer.
getCheckpointObject(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.ICheckpoint
Get the current checkpoint stored for the specified shard, which holds the sequence numbers for the checkpoint and pending checkpoint.
getCloudWatchClientConfiguration() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getCloudWatchCredentialsProvider() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getConcurrencyToken() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
Concurrency token for the lease that this shard is part of
getConcurrencyToken() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
getConfiguration(Properties) - Method in class com.amazonaws.services.kinesis.clientlibrary.config.KinesisClientLibConfigurator
Return a KinesisClientLibConfiguration with variables configured as specified by the properties in config stream.
getConfiguration(InputStream) - Method in class com.amazonaws.services.kinesis.clientlibrary.config.KinesisClientLibConfigurator
 
getCurrentlyHeldLease(String) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
getCurrentlyHeldLease(String) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
getCurrentlyHeldLease(String) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
 
getCurrentlyHeldLeases() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
getCurrentlyHeldLeases() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
 
getData() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required bytes data = 3;
getData() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
required bytes data = 3;
getData() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
required bytes data = 3;
getDataFetcher() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy
 
getDataFetcher() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetrievalStrategy
Returns the KinesisDataFetcher used to getRecords from Kinesis.
getDataFetcher() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SynchronousGetRecordsRetrievalStrategy
 
getDefaultInstance() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
getDefaultInstance() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
getDefaultInstance() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
getDefaultInstanceForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
getDefaultInstanceForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
getDefaultInstanceForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
getDefaultInstanceForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
getDefaultInstanceForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
getDefaultInstanceForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
getDefaultLeaseRenewalExecutorService(int) - Static method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Returns executor service that should be used for lease renewal.
getDescriptor() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
getDescriptor() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
getDescriptor() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages
 
getDescriptor() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
getDescriptor() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
getDescriptor() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
getDescriptor() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
getDescriptorForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
getDescriptorForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
getDescriptorForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
getDimensions() - Method in class com.amazonaws.services.kinesis.metrics.impl.DimensionTrackingMetricsScope
 
getDynamoDBClientConfiguration() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getDynamoDBCredentialsProvider() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getDynamoDBEndpoint() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getDynamoEvictLeaseUpdate(KinesisClientLease) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoEvictLeaseUpdate(Lease) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoEvictLeaseUpdate(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getDynamoHashKey(KinesisClientLease) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoHashKey(String) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoHashKey(String) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoHashKey(Lease) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoHashKey(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getDynamoHashKey(String) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
Special getDynamoHashKey implementation used by ILeaseManager.getLease().
getDynamoLeaseCounterExpectation(KinesisClientLease) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoLeaseCounterExpectation(Lease) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoLeaseCounterExpectation(Long) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoLeaseCounterExpectation(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getDynamoLeaseCounterUpdate(KinesisClientLease) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoLeaseCounterUpdate(Lease) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoLeaseCounterUpdate(Long) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoLeaseCounterUpdate(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getDynamoLeaseOwnerExpectation(KinesisClientLease) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoLeaseOwnerExpectation(Lease) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoLeaseOwnerExpectation(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getDynamoNonexistantExpectation() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoNonexistantExpectation() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoNonexistantExpectation() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getDynamoTakeLeaseUpdate(KinesisClientLease, String) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoTakeLeaseUpdate(Lease, String) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoTakeLeaseUpdate(T, String) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getDynamoUpdateLeaseUpdate(KinesisClientLease) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getDynamoUpdateLeaseUpdate(Lease) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getDynamoUpdateLeaseUpdate(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getEpsilonMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getExecutorService() - Method in class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 
getExplicitHashKey() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
 
getExplicitHashKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
optional uint64 explicit_hash_key_index = 2;
getExplicitHashKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
optional uint64 explicit_hash_key_index = 2;
getExplicitHashKeyIndex() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
optional uint64 explicit_hash_key_index = 2;
getExplicitHashKeyTable(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTable(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTable(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableBytes(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableBytes(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableBytes(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableCount() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string explicit_hash_key_table = 2;
getExplicitHashKeyTableList() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string explicit_hash_key_table = 2;
getExtendedSequenceNumber() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput
getFailoverTimeMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getGetRecordsRetrievalStrategy() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.BlockingGetRecordsCache
 
getGetRecordsRetrievalStrategy() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache
 
getGetRecordsRetrievalStrategy() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PrefetchGetRecordsCache
 
getIdleTimeBetweenReadsInMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getInitialLeaseTableReadCapacity() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getInitialLeaseTableWriteCapacity() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getInitialPositionInStream() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended
Get the initial position in the stream where the application should start from.
getInitialPositionInStream() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getInitialPositionInStreamExtended() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Keeping it protected to forbid outside callers from depending on this internal object.
getIterator(String, String, String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
Fetch a shard iterator from the specified position in the shard.
getIterator(String, String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
Fetch a shard iterator from the specified position in the shard.
getIterator(String, Date) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
Fetch a shard iterator from the specified position in the shard.
getIterator(String, String, String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Fetch a shard iterator from the specified position in the shard.
getIterator(String, String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Fetch a shard iterator from the specified position in the shard.
getIterator(String, Date) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Fetch a shard iterator from the specified position in the shard.
getIterator(String, String, String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Fetch a shard iterator from the specified position in the shard.
getIterator(String, String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Fetch a shard iterator from the specified position in the shard.
getIterator(String, Date) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Fetch a shard iterator from the specified position in the shard.
getKey() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
required string key = 1;
getKey() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
required string key = 1;
getKey() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.TagOrBuilder
required string key = 1;
getKey(String) - Method in class com.amazonaws.services.kinesis.metrics.impl.AccumulateByNameMetricsScope
 
getKey(String) - Method in class com.amazonaws.services.kinesis.metrics.impl.AccumulatingMetricsScope
 
getKeyBytes() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
required string key = 1;
getKeyBytes() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
required string key = 1;
getKeyBytes() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.TagOrBuilder
required string key = 1;
getKeySchema() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
getKeySchema() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
getKeySchema() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
 
getKinesisClientConfiguration() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getKinesisClientLibConfiguration() - Method in class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 
getKinesisCredentialsProvider() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getKinesisEndpoint() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getLastCounterIncrementNanos() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
getLease(String) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
getLease(String) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
 
getLeaseCounter() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
getLeaseCountThatCanBeTaken(Collection<T>) - Method in class com.amazonaws.services.kinesis.leases.impl.GenericLeaseSelector
Provides the number of leases that should be taken by the worker.
getLeaseCountThatCanBeTaken(Collection<T>) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.LeaseSelector
Provides the number of leases that should be taken by the worker.
getLeaseKey() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
getLeaseOwner() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
getLeasesToTakeFromExpiredLeases(List<T>, int) - Method in class com.amazonaws.services.kinesis.leases.impl.GenericLeaseSelector
Provides the list of leases to be taken.
getLeasesToTakeFromExpiredLeases(List<T>, int) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.LeaseSelector
Provides the list of leases to be taken.
getMaxLeasesForWorker() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getMaxLeasesToStealAtOneTime() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getMaxRecords() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getMetricsBufferTimeMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getMetricsEnabledDimensions() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getMetricsLevel() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getMetricsMaxQueueSize() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getMetricsScope() - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
getMillisBehindLatest() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
Get milliseconds behind latest.
getName() - Method in enum com.amazonaws.services.kinesis.metrics.interfaces.MetricsLevel
Returns the name for this metrics level.
getNextRecords(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetriever
 
getNextResult() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.BlockingGetRecordsCache
 
getNextResult() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache
This method returns the next set of records from the Cache if present, or blocks the request till it gets the next set of records back from Kinesis.
getNextResult() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PrefetchGetRecordsCache
 
getOwnerSwitchesSinceCheckpoint() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
getParentShardIds() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
A list of shards that are parents of this shard.
getParentShardIds() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
getParentShardPollIntervalMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getParserForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
getParserForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
getParserForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
getPartitionKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required uint64 partition_key_index = 1;
getPartitionKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
required uint64 partition_key_index = 1;
getPartitionKeyIndex() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
required uint64 partition_key_index = 1;
getPartitionKeyTable(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
getPartitionKeyTable(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string partition_key_table = 1;
getPartitionKeyTable(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string partition_key_table = 1;
getPartitionKeyTableBytes(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
getPartitionKeyTableBytes(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string partition_key_table = 1;
getPartitionKeyTableBytes(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string partition_key_table = 1;
getPartitionKeyTableCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
getPartitionKeyTableCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string partition_key_table = 1;
getPartitionKeyTableCount() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string partition_key_table = 1;
getPartitionKeyTableList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
getPartitionKeyTableList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated string partition_key_table = 1;
getPartitionKeyTableList() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated string partition_key_table = 1;
getPendingCheckpoint() - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IPreparedCheckpointer
 
getPendingCheckpoint() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.DoesNothingPreparedCheckpointer
getPendingCheckpoint() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PreparedCheckpointer
getPendingCheckpoint() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
getPendingCheckpointSequenceNumber() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput
Get pending checkpoint ExtendedSequenceNumber.
getProxy(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxyFactory
Deprecated.
Return an IKinesisProxy object for the specified stream.
getProxy(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxyFactory
Deprecated.
Return an IKinesisProxy object for the specified stream.
getReason() - Method in class com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage
 
getRecordProcessorFactory() - Method in class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 
getRecords(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy
 
getRecords(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetrievalStrategy
Gets a set of records from Kinesis.
getRecords(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SynchronousGetRecordsRetrievalStrategy
 
getRecords(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
getRecords(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated .Record records = 3;
getRecords(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated .Record records = 3;
getRecords() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
Get records.
getRecordsBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
getRecordsBuilderList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
GetRecordsCache - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
This class is used as a cache for Prefetching data from Kinesis.
getRecordsCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
getRecordsCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated .Record records = 3;
getRecordsCount() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated .Record records = 3;
getRecordsList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
getRecordsList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated .Record records = 3;
getRecordsList() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated .Record records = 3;
getRecordsOrBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
getRecordsOrBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated .Record records = 3;
getRecordsOrBuilder(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated .Record records = 3;
getRecordsOrBuilderList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
getRecordsOrBuilderList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
repeated .Record records = 3;
getRecordsOrBuilderList() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecordOrBuilder
repeated .Record records = 3;
GetRecordsRetrievalStrategy - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Represents a strategy to retrieve records from Kinesis.
GetRecordsRetriever - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
This class uses the GetRecordsRetrievalStrategy class to retrieve the next set of records and update the cache.
getRegionName() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getResponseFor() - Method in class com.amazonaws.services.kinesis.multilang.messages.StatusMessage
 
getResult() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.DataFetcherResult
The result of the request to Kinesis
getSequenceNumber() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
 
getSerializedSize() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
getSerializedSize() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
getSerializedSize() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
getShard(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxyExtended
Get the Shard corresponding to shardId associated with this IKinesisProxy.
getShard(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Get the Shard corresponding to shardId associated with this IKinesisProxy.
getShardId() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
The shardId that this ShardInfo contains data about
getShardId() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput
Get shard Id.
getShardList() - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
Fetch all the shards defined for the stream (e.g.
getShardList() - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Fetch all the shards defined for the stream (e.g.
getShardList() - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Fetch all the shards defined for the stream (e.g.
getShardPrioritizationStrategy() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getShardSyncIntervalMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getShardSyncStrategyType() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getShutdownGraceMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getShutdownReason() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput
Get shutdown reason.
getSkipShardSyncAtWorkerInitializationIfLeasesExist() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getStrategyType() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategy
Can be used to provide a custom name for the implemented strategy.
getStreamInfo(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
Deprecated.
Going forward this method is being deprecated. This method uses DescribeStream call, which is throttled at 10 calls per account by default. If possible try to use ListShards call available in the client, or use the getShardList or getAllShards to get shard info. To make DescribeStream calls, use the AmazonKinesis client directly instead of using KinesisProxy. This method will be removed in the next major/minor release.
getStreamInfo(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Deprecated.
getStreamInfo(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Fetch information about stream.
getStreamName() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getSubSequenceNumber() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
 
getSubSequenceNumber() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
 
getTableName() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getTags(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
getTags(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
repeated .Tag tags = 4;
getTags(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
repeated .Tag tags = 4;
getTagsBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
getTagsBuilderList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
getTagsCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
getTagsCount() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
repeated .Tag tags = 4;
getTagsCount() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
repeated .Tag tags = 4;
getTagsList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
getTagsList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
repeated .Tag tags = 4;
getTagsList() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
repeated .Tag tags = 4;
getTagsOrBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
getTagsOrBuilder(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
repeated .Tag tags = 4;
getTagsOrBuilder(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
repeated .Tag tags = 4;
getTagsOrBuilderList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
getTagsOrBuilderList() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
repeated .Tag tags = 4;
getTagsOrBuilderList() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
repeated .Tag tags = 4;
getTaskBackoffTimeMillis() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getTime() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
Overrideable for testing purposes.
getTimeSpentInCache() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
 
getTimestamp() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended
Get the timestamp from where we need to start the application.
getTimestampAtInitialPositionInStream() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getUnknownFields() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
getUnknownFields() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
getUnknownFields() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
getValue() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
optional string value = 2;
getValue() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
optional string value = 2;
getValue() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.TagOrBuilder
optional string value = 2;
getValue() - Method in enum com.amazonaws.services.kinesis.metrics.interfaces.MetricsLevel
Returns the value for this metrics level.
getValueBytes() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
optional string value = 2;
getValueBytes() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
optional string value = 2;
getValueBytes() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.TagOrBuilder
optional string value = 2;
getWorkerIdentifier() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
getWorkerIdentifier() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
getWorkerIdentifier() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseTaker
getWorkerIdentifier() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseTaker
 
gracefuleShutdownStarted - Variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
 
gracefulShutdownCoordinator - Variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
 

H

hasData() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required bytes data = 3;
hasData() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
required bytes data = 3;
hasData() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
required bytes data = 3;
hasExplicitHashKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
optional uint64 explicit_hash_key_index = 2;
hasExplicitHashKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
optional uint64 explicit_hash_key_index = 2;
hasExplicitHashKeyIndex() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
optional uint64 explicit_hash_key_index = 2;
hasGracefulShutdownStarted() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
 
hashCode() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
hashCode() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
 
hashCode() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
hashCode() - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
hashCode() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
hashCode() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWMetricKey
 
hashCode() - Method in class com.amazonaws.services.kinesis.metrics.impl.MetricDatumWithKey
 
hasKey() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
required string key = 1;
hasKey() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
required string key = 1;
hasKey() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.TagOrBuilder
required string key = 1;
hasPartitionKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required uint64 partition_key_index = 1;
hasPartitionKeyIndex() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
required uint64 partition_key_index = 1;
hasPartitionKeyIndex() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.RecordOrBuilder
required uint64 partition_key_index = 1;
hasValue() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
optional string value = 2;
hasValue() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
optional string value = 2;
hasValue() - Method in interface com.amazonaws.services.kinesis.clientlibrary.types.Messages.TagOrBuilder
optional string value = 2;
HTTP_PROXY_ENV_VAR - Static variable in class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 

I

ICheckpoint - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces
Interface for checkpoint trackers.
ICWMetricsPublisher<KeyType> - Interface in com.amazonaws.services.kinesis.metrics.impl
An ICWMetricsPublisher is a publisher that contains the logic to publish metrics.
IKinesisClientLeaseManager - Interface in com.amazonaws.services.kinesis.leases.interfaces
A decoration of ILeaseManager that adds methods to get/update checkpoints.
IKinesisProxy - Interface in com.amazonaws.services.kinesis.clientlibrary.proxies
Kinesis proxy interface.
IKinesisProxyExtended - Interface in com.amazonaws.services.kinesis.clientlibrary.proxies
Kinesis proxy interface extended with addition method(s).
IKinesisProxyFactory - Interface in com.amazonaws.services.kinesis.clientlibrary.proxies
Deprecated.
Deprecating since KinesisProxy is just created once, there is no use of a factory. There is no replacement for this class. This class will be removed in the next major/minor release.
ILeaseManager<T extends Lease> - Interface in com.amazonaws.services.kinesis.leases.interfaces
Supports basic CRUD operations for Leases.
ILeaseRenewer<T extends Lease> - Interface in com.amazonaws.services.kinesis.leases.interfaces
ILeaseRenewer objects are used by LeaseCoordinator to renew leases held by the LeaseCoordinator.
ILeaseSerializer<T extends Lease> - Interface in com.amazonaws.services.kinesis.leases.interfaces
Utility class that manages the mapping of Lease objects/operations to records in DynamoDB.
ILeaseTaker<T extends Lease> - Interface in com.amazonaws.services.kinesis.leases.interfaces
ILeaseTaker is used by LeaseCoordinator to take new leases, or leases that other workers fail to renew.
IMetricsFactory - Interface in com.amazonaws.services.kinesis.metrics.interfaces
Factory for MetricsScope objects.
IMetricsScope - Interface in com.amazonaws.services.kinesis.metrics.interfaces
An IMetricsScope represents a set of metric data that share a set of dimensions.
InitializationInput - Class in com.amazonaws.services.kinesis.clientlibrary.types
Container for the parameters to the IRecordProcessor's initialize method.
InitializationInput() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput
Default constructor.
initialize(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor
Invoked by the Amazon Kinesis Client Library before data records are delivered to the RecordProcessor instance (via processRecords).
initialize(InitializationInput) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor
Invoked by the Amazon Kinesis Client Library before data records are delivered to the RecordProcessor instance (via processRecords).
initialize() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
Bootstrap initial set of leases from the LeaseManager (e.g.
initialize() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
Bootstrap initial set of leases from the LeaseManager (e.g.
initialize(InitializationInput) - Method in class com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor
 
InitializeMessage - Class in com.amazonaws.services.kinesis.multilang.messages
An initialize message is sent to the client's subprocess to indicate that it should perform its initialization steps.
InitializeMessage() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.InitializeMessage
Default constructor.
InitializeMessage(InitializationInput) - Constructor for class com.amazonaws.services.kinesis.multilang.messages.InitializeMessage
Convenience constructor.
InitialPositionInStream - Enum in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Used to specify the position in the stream where a new application should start from.
InitialPositionInStreamExtended - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Class that houses the entities needed to specify the position in the stream from where a new application should start.
interceptAddData(String, double, StandardUnit, IMetricsScope) - Method in class com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory
 
interceptAddData(String, double, StandardUnit, MetricsLevel, IMetricsScope) - Method in class com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory
 
interceptAddDimension(String, String, IMetricsScope) - Method in class com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory
 
interceptCreateMetrics(IMetricsScope) - Method in class com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory
 
interceptEnd(IMetricsScope) - Method in class com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory
 
InterceptingMetricsFactory - Class in com.amazonaws.services.kinesis.metrics.impl
 
InterceptingMetricsFactory(IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory
 
internalGetFieldAccessorTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
internalGetFieldAccessorTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
internalGetFieldAccessorTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
internalGetFieldAccessorTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
internalGetFieldAccessorTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
internalGetFieldAccessorTable() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
InvalidStateException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions
This is thrown when the Amazon Kinesis Client Library encounters issues with its internal state (e.g.
InvalidStateException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.InvalidStateException
 
InvalidStateException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.InvalidStateException
 
InvalidStateException - Exception in com.amazonaws.services.kinesis.leases.exceptions
Indicates that a lease operation has failed because DynamoDB is an invalid state.
InvalidStateException(Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.InvalidStateException
 
InvalidStateException(String, Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.InvalidStateException
 
InvalidStateException(String) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.InvalidStateException
 
IPreparedCheckpointer - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces
Objects of this class are prepared to checkpoint at a specific sequence number.
IRecordProcessor - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces
The Amazon Kinesis Client Library will instantiate record processors to process data records fetched from Amazon Kinesis.
IRecordProcessor - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces.v2
The Amazon Kinesis Client Library will instantiate record processors to process data records fetched from Amazon Kinesis.
IRecordProcessorCheckpointer - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces
Used by RecordProcessors when they want to checkpoint their progress.
IRecordProcessorFactory - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces
The Amazon Kinesis Client Library will use this to instantiate a record processor per shard.
IRecordProcessorFactory - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces.v2
The Amazon Kinesis Client Library will use this to instantiate a record processor per shard.
isAggregated() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
 
isCandidateForCleanup(KinesisClientLease, Set<String>) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.LeaseCleanupValidator
 
isCompleted() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
Whether the shard has been completely processed or not.
isEmpty() - Method in class com.amazonaws.services.kinesis.metrics.impl.MetricAccumulatingQueue
 
isExpired(long, long) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
IShutdownNotificationAware - Interface in com.amazonaws.services.kinesis.clientlibrary.interfaces.v2
Allows a record processor to indicate it's aware of requested shutdowns, and handle the request.
isInitialized() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
isInitialized() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
isInitialized() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
isInitialized() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
isInitialized() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
isInitialized() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
isLeader(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.LeaderDecider
Method invoked to check the given workerId corresponds to one of the workers designated to execute shard-syncs periodically.
isLeaseTableEmpty() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Check (synchronously) if there are any leases in the lease table.
isLeaseTableEmpty() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Check (synchronously) if there are any leases in the lease table.
isMetricsScopePresent() - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
Checks if current metricsscope is present or not.
isRunning() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
isShardEnd() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.DataFetcherResult
Indicates whether this result is at the end of the shard or not
isShutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy
 
isShutdown() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetrievalStrategy
Returns whether this strategy has been shutdown.
isShutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SynchronousGetRecordsRetrievalStrategy
 
isShutdown() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
 

J

JsonFriendlyRecord - Class in com.amazonaws.services.kinesis.multilang.messages
Class for encoding Record objects to json.
JsonFriendlyRecord() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.JsonFriendlyRecord
Default Constructor.
JsonFriendlyRecord(Record) - Constructor for class com.amazonaws.services.kinesis.multilang.messages.JsonFriendlyRecord
Convenience constructor.

K

key - Variable in class com.amazonaws.services.kinesis.metrics.impl.MetricDatumWithKey
 
KEY_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
KINESIS_CLIENT_LIB_USER_AGENT - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
User agent set when Amazon Kinesis Client Library makes AWS requests.
KinesisClientLease - Class in com.amazonaws.services.kinesis.leases.impl
A Lease subclass containing KinesisClientLibrary related fields for checkpoints.
KinesisClientLease() - Constructor for class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
KinesisClientLease(KinesisClientLease) - Constructor for class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
 
KinesisClientLeaseManager - Class in com.amazonaws.services.kinesis.leases.impl
An implementation of LeaseManager for the KinesisClientLibrary - takeLease updates the ownerSwitchesSinceCheckpoint field.
KinesisClientLeaseManager(String, AmazonDynamoDB) - Constructor for class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseManager
Constructor.
KinesisClientLeaseManager(String, AmazonDynamoDB, boolean) - Constructor for class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseManager
Constructor for integration tests - see comment on superclass for documentation on setting the consistentReads flag.
KinesisClientLeaseSerializer - Class in com.amazonaws.services.kinesis.leases.impl
An implementation of ILeaseSerializer for KinesisClientLease objects.
KinesisClientLeaseSerializer() - Constructor for class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
KinesisClientLibConfiguration - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Configuration for the Amazon Kinesis Client Library.
KinesisClientLibConfiguration(String, String, AWSCredentialsProvider, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Constructor.
KinesisClientLibConfiguration(String, String, AWSCredentialsProvider, AWSCredentialsProvider, AWSCredentialsProvider, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Constructor.
KinesisClientLibConfiguration(String, String, String, InitialPositionInStream, AWSCredentialsProvider, AWSCredentialsProvider, AWSCredentialsProvider, long, String, int, long, boolean, long, long, boolean, ClientConfiguration, ClientConfiguration, ClientConfiguration, long, long, int, boolean, String, long) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
KinesisClientLibConfiguration(String, String, String, String, InitialPositionInStream, AWSCredentialsProvider, AWSCredentialsProvider, AWSCredentialsProvider, long, String, int, long, boolean, long, long, boolean, ClientConfiguration, ClientConfiguration, ClientConfiguration, long, long, int, boolean, String, long) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
KinesisClientLibConfiguration(String, String, String, String, InitialPositionInStream, AWSCredentialsProvider, AWSCredentialsProvider, AWSCredentialsProvider, long, String, int, long, boolean, long, long, boolean, ClientConfiguration, ClientConfiguration, ClientConfiguration, long, long, int, boolean, String, RecordsFetcherFactory) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
KinesisClientLibConfigurator - Class in com.amazonaws.services.kinesis.clientlibrary.config
KinesisClientLibConfigurator constructs a KinesisClientLibConfiguration from java properties file.
KinesisClientLibConfigurator() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.config.KinesisClientLibConfigurator
Constructor.
KinesisClientLibDependencyException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions
This is thrown when the Amazon Kinesis Client Library encounters issues talking to its dependencies (e.g.
KinesisClientLibDependencyException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibDependencyException
 
KinesisClientLibDependencyException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibDependencyException
 
KinesisClientLibException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions
Abstract class for exceptions of the Amazon Kinesis Client Library.
KinesisClientLibException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibException
Constructor.
KinesisClientLibException(String, Throwable) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibException
Constructor.
KinesisClientLibIOException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions.internal
Thrown when we encounter issues when reading/writing information (e.g.
KinesisClientLibIOException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.internal.KinesisClientLibIOException
Constructor.
KinesisClientLibIOException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.internal.KinesisClientLibIOException
Constructor.
KinesisClientLibNonRetryableException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions
Non-retryable exceptions.
KinesisClientLibNonRetryableException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibNonRetryableException
Constructor.
KinesisClientLibNonRetryableException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibNonRetryableException
Constructor.
KinesisClientLibRetryableException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions
Retryable exceptions (e.g.
KinesisClientLibRetryableException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibRetryableException
Constructor.
KinesisClientLibRetryableException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibRetryableException
Constructor.
KinesisProxy - Class in com.amazonaws.services.kinesis.clientlibrary.proxies
Kinesis proxy - used to make calls to Amazon Kinesis (e.g.
KinesisProxy(String, AWSCredentialsProvider, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Deprecated.
Deprecating constructor, this constructor doesn't use AWS best practices, moving forward please use KinesisProxy.KinesisProxy(KinesisClientLibConfiguration, AmazonKinesis) or KinesisProxy.KinesisProxy(String, AmazonKinesis, long, int, long, int) to create the object. Will be removed in the next major/minor release.
KinesisProxy(String, AWSCredentialsProvider, String, String, String, long, int, long, int) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Deprecated.
Deprecating constructor, this constructor doesn't use AWS best practices, moving forward please use KinesisProxy.KinesisProxy(KinesisClientLibConfiguration, AmazonKinesis) or KinesisProxy.KinesisProxy(String, AmazonKinesis, long, int, long, int) to create the object. Will be removed in the next major/minor release.
KinesisProxy(String, AWSCredentialsProvider, AmazonKinesis, long, int, long, int) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Deprecated.
Deprecating constructor, this constructor doesn't use AWS best practices, moving forward please use KinesisProxy.KinesisProxy(KinesisClientLibConfiguration, AmazonKinesis) or KinesisProxy.KinesisProxy(String, AmazonKinesis, long, int, long, int) to create the object. Will be removed in the next major/minor release.
KinesisProxy(KinesisClientLibConfiguration, AmazonKinesis) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
Public constructor.
KinesisProxy(String, AmazonKinesis, long, int, long, int) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
 
KinesisProxyFactory - Class in com.amazonaws.services.kinesis.clientlibrary.proxies
Deprecated.
Will be removed since proxy is created only once, we don't need a factory. There is no replacement for this class. Will be removed in the next major/minor release.
KinesisProxyFactory(AWSCredentialsProvider, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxyFactory
Deprecated.
Constructor for creating a KinesisProxy factory, using the specified credentials provider and endpoint.
KinesisProxyFactory(AWSCredentialsProvider, ClientConfiguration, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxyFactory
Deprecated.
Constructor for KinesisProxy factory using the client configuration to use when interacting with Kinesis.
KinesisProxyFactory(AWSCredentialsProvider, AmazonKinesis) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxyFactory
Deprecated.
This constructor may be used to specify the AmazonKinesisClient to use.

L

LATEST - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
Special value for LATEST.
LeaderDecider - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Used in conjunction with periodic shard sync.
Lease - Class in com.amazonaws.services.kinesis.leases.impl
This class contains data pertaining to a Lease.
Lease() - Constructor for class com.amazonaws.services.kinesis.leases.impl.Lease
Constructor.
Lease(Lease) - Constructor for class com.amazonaws.services.kinesis.leases.impl.Lease
Copy constructor, used by clone().
Lease(String, String, Long, UUID, Long) - Constructor for class com.amazonaws.services.kinesis.leases.impl.Lease
 
LEASE_COUNTER_KEY - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
LEASE_KEY_KEY - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
LEASE_OWNER_KEY - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
LeaseCleanupValidator - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Represents the class that decides if a lease is eligible for cleanup.
LeaseCoordinator<T extends Lease> - Class in com.amazonaws.services.kinesis.leases.impl
LeaseCoordinator abstracts away LeaseTaker and LeaseRenewer from the application code that's using leasing.
LeaseCoordinator(ILeaseManager<T>, String, long, long) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Constructor.
LeaseCoordinator(ILeaseManager<T>, LeaseSelector<T>, String, long, long) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Constructor.
LeaseCoordinator(ILeaseManager<T>, String, long, long, IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Constructor.
LeaseCoordinator(ILeaseManager<T>, LeaseSelector<T>, String, long, long, IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Constructor.
LeaseCoordinator(ILeaseManager<T>, String, long, long, int, int, int, IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Constructor.
LeaseCoordinator(ILeaseManager<T>, LeaseSelector<T>, String, long, long, int, int, int, IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
LeaseCoordinator(ILeaseTaker<T>, ILeaseRenewer<T>, long, long, int, int, IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
LeaseManager<T extends Lease> - Class in com.amazonaws.services.kinesis.leases.impl
An implementation of ILeaseManager that uses DynamoDB.
LeaseManager(String, AmazonDynamoDB, ILeaseSerializer<T>) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Constructor.
LeaseManager(String, AmazonDynamoDB, ILeaseSerializer<T>, boolean) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Constructor for test cases - allows control of consistent reads.
LeaseRenewer<T extends Lease> - Class in com.amazonaws.services.kinesis.leases.impl
An implementation of ILeaseRenewer that uses DynamoDB via LeaseManager.
LeaseRenewer(ILeaseManager<T>, String, long, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
Constructor.
LeaseSelector<T extends Lease> - Interface in com.amazonaws.services.kinesis.leases.interfaces
LeaseSelector abstracts away the lease selection logic from the application code that's using leasing.
LeaseSerializer - Class in com.amazonaws.services.kinesis.leases.impl
An implementation of ILeaseSerializer for basic Lease objects.
LeaseSerializer() - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
LeaseSerializer(Class<? extends Lease>) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
leaseTableExists() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
leaseTableExists() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
 
LeaseTaker<T extends Lease> - Class in com.amazonaws.services.kinesis.leases.impl
An implementation of ILeaseTaker that uses DynamoDB via LeaseManager.
LeaseTaker(ILeaseManager<T>, String, long) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseTaker
 
LeaseTaker(ILeaseManager<T>, LeaseSelector<T>, String, long) - Constructor for class com.amazonaws.services.kinesis.leases.impl.LeaseTaker
 
LeasingException - Exception in com.amazonaws.services.kinesis.leases.exceptions
Top-level exception type for all exceptions thrown by the leasing code.
LeasingException(Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.LeasingException
 
LeasingException(String, Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.LeasingException
 
LeasingException(String) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.LeasingException
 
listLeases() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
List all objects in table synchronously.
listLeases() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
List all objects in table synchronously.
LogMetricsFactory - Class in com.amazonaws.services.kinesis.metrics.impl
An IMetricsFactory that creates IMetricsScopes that output themselves via log4j.
LogMetricsFactory() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.LogMetricsFactory
 
LogMetricsScope - Class in com.amazonaws.services.kinesis.metrics.impl
An AccumulatingMetricsScope that outputs via log4j.
LogMetricsScope() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.LogMetricsScope
 

M

main(String[]) - Static method in class com.amazonaws.services.kinesis.multilang.MultiLangDaemon
 
MAX_CACHE_MISSES_BEFORE_RELOAD - Static variable in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
 
mergeFrom(Message) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
mergeFrom(Messages.AggregatedRecord) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
 
mergeFrom(Message) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
mergeFrom(Messages.Record) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
 
mergeFrom(Message) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
mergeFrom(Messages.Tag) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
 
Message - Class in com.amazonaws.services.kinesis.multilang.messages
Abstract class for all messages that are sent to the client's process.
Message() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.Message
Default constructor.
Messages - Class in com.amazonaws.services.kinesis.clientlibrary.types
 
Messages.AggregatedRecord - Class in com.amazonaws.services.kinesis.clientlibrary.types
Protobuf type AggregatedRecord
Messages.AggregatedRecord.Builder - Class in com.amazonaws.services.kinesis.clientlibrary.types
Protobuf type AggregatedRecord
Messages.AggregatedRecordOrBuilder - Interface in com.amazonaws.services.kinesis.clientlibrary.types
 
Messages.Record - Class in com.amazonaws.services.kinesis.clientlibrary.types
Protobuf type Record
Messages.Record.Builder - Class in com.amazonaws.services.kinesis.clientlibrary.types
Protobuf type Record
Messages.RecordOrBuilder - Interface in com.amazonaws.services.kinesis.clientlibrary.types
 
Messages.Tag - Class in com.amazonaws.services.kinesis.clientlibrary.types
Protobuf type Tag
Messages.Tag.Builder - Class in com.amazonaws.services.kinesis.clientlibrary.types
Protobuf type Tag
Messages.TagOrBuilder - Interface in com.amazonaws.services.kinesis.clientlibrary.types
 
MetricAccumulatingQueue<KeyType> - Class in com.amazonaws.services.kinesis.metrics.impl
Helper class for accumulating MetricDatums with the same name and dimensions.
MetricAccumulatingQueue(int) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.MetricAccumulatingQueue
 
MetricDatumWithKey<KeyType> - Class in com.amazonaws.services.kinesis.metrics.impl
This class is used to store a MetricDatum as well as KeyType which stores specific information about that particular MetricDatum.
MetricDatumWithKey(KeyType, MetricDatum) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.MetricDatumWithKey
 
METRICS_ALWAYS_ENABLED_DIMENSIONS - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Metrics dimensions that always will be enabled regardless of the config provided by user.
METRICS_DIMENSIONS_ALL - Static variable in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Metrics dimensions that signify all possible dimensions.
METRICS_DIMENSIONS_ALL - Static variable in interface com.amazonaws.services.kinesis.metrics.interfaces.IMetricsScope
Value that signifies that all dimensions are allowed for the metrics scope.
MetricsCollectingKinesisProxyDecorator - Class in com.amazonaws.services.kinesis.clientlibrary.proxies
IKinesisProxy implementation that wraps another implementation and collects metrics.
MetricsCollectingKinesisProxyDecorator(String, IKinesisProxy, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator
Constructor.
metricsFactory - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
MetricsHelper - Class in com.amazonaws.services.kinesis.metrics.impl
MetricsHelper assists with common metrics operations, most notably the storage of IMetricsScopes objects in a ThreadLocal so we don't have to pass one throughout the whole call stack.
MetricsHelper() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
MetricsLevel - Enum in com.amazonaws.services.kinesis.metrics.interfaces
This class defines a set of standard metrics levels that can be used to control which metrics get emitted.
MultiLangDaemon - Class in com.amazonaws.services.kinesis.multilang
Main app that launches the worker that runs the multi-language record processor.
MultiLangDaemon(KinesisClientLibConfiguration, MultiLangRecordProcessorFactory, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.multilang.MultiLangDaemon
Constructor.
MultiLangDaemon(Worker) - Constructor for class com.amazonaws.services.kinesis.multilang.MultiLangDaemon
 
MultiLangDaemonConfig - Class in com.amazonaws.services.kinesis.multilang
This class captures the configuration needed to run the MultiLangDaemon.
MultiLangDaemonConfig(String) - Constructor for class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
Constructor.
MultiLangDaemonConfig(String, ClassLoader) - Constructor for class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 
MultiLangDaemonConfig(String, ClassLoader, KinesisClientLibConfigurator) - Constructor for class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 
MultiLangRecordProcessor - Class in com.amazonaws.services.kinesis.multilang
A record processor that manages creating a child process that implements the multi language protocol and connecting that child process's input and outputs to a MultiLangProtocol object and calling the appropriate methods on that object when its corresponding MultiLangRecordProcessor.initialize(com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput), MultiLangRecordProcessor.processRecords(com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput), and MultiLangRecordProcessor.shutdown(com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput) methods are called.
MultiLangRecordProcessorFactory - Class in com.amazonaws.services.kinesis.multilang
MultiLangRecordProcessorFactory(String, ExecutorService, KinesisClientLibConfiguration) - Constructor for class com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessorFactory
 
MultiLangRecordProcessorFactory(String, ExecutorService, ObjectMapper, KinesisClientLibConfiguration) - Constructor for class com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessorFactory
 

N

NamedThreadFactory - Class in com.amazonaws.services.kinesis.clientlibrary.utils
Custom thread factory that sets thread names based on the specified prefix.
NamedThreadFactory(String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.utils.NamedThreadFactory
Construct a thread factory that uses the specified parameter as the thread prefix.
newBuilder() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
newBuilder(Messages.AggregatedRecord) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
newBuilder() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
newBuilder(Messages.Record) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
newBuilder() - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
newBuilder(Messages.Tag) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
newBuilderForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
newBuilderForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
newBuilderForType() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
newInitialPosition(InitialPositionInStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended
 
newInitialPositionAtTimestamp(Date) - Static method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended
 
newThread(Runnable) - Method in class com.amazonaws.services.kinesis.clientlibrary.utils.NamedThreadFactory
 
NoOpShardPrioritization - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Shard Prioritization that returns the same original list of shards without any modifications.
NoOpShardPrioritization() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.NoOpShardPrioritization
Empty constructor for NoOp Shard Prioritization.
NoOpWorkerStateChangeListener - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
NoOpWorkerStateChangeListener() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.NoOpWorkerStateChangeListener
Empty constructor for NoOp Worker State Change Listener
NullMetricsFactory - Class in com.amazonaws.services.kinesis.metrics.impl
 
NullMetricsFactory() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.NullMetricsFactory
 
NullMetricsScope - Class in com.amazonaws.services.kinesis.metrics.impl
 
NullMetricsScope() - Constructor for class com.amazonaws.services.kinesis.metrics.impl.NullMetricsScope
 

O

offer(KeyType, MetricDatum) - Method in class com.amazonaws.services.kinesis.metrics.impl.MetricAccumulatingQueue
We use a queue and a map in this method.
onFoundCompletedShard() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategy
Invoked when a completed shard is found.
onShardConsumerShutDown() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategy
Invoked when ShardConsumer is shutdown.
onWorkerInitialization() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategy
Invoked at worker initialization
onWorkerShutDown() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategy
Invoked when worker is shutdown.
onWorkerStateChange(WorkerStateChangeListener.WorkerState) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.NoOpWorkerStateChangeListener
 
onWorkerStateChange(WorkerStateChangeListener.WorkerState) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.WorkerStateChangeListener
 
OPERATION_DIMENSION_NAME - Static variable in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 

P

PARENT_SHARD_ID_KEY - Variable in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
ParentsFirstShardPrioritization - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Shard Prioritization that prioritizes parent shards first.
ParentsFirstShardPrioritization(int) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ParentsFirstShardPrioritization
Creates ParentFirst prioritization with filtering based on depth of the shard.
parseDelimitedFrom(InputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseDelimitedFrom(InputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseDelimitedFrom(InputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(ByteString) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(byte[]) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(InputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(CodedInputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
parseFrom(ByteString) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(byte[]) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(InputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(CodedInputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
parseFrom(ByteString) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(byte[]) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(InputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(CodedInputStream) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
PARSER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
PARSER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
PARSER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
PARTITION_KEY_INDEX_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
PARTITION_KEY_TABLE_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
PrefetchGetRecordsCache - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
This is the prefetch caching class, this class spins up a thread if prefetching is enabled.
PrefetchGetRecordsCache(int, int, int, int, GetRecordsRetrievalStrategy, ExecutorService, long, IMetricsFactory, String, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PrefetchGetRecordsCache
Constructor for the PrefetchGetRecordsCache.
prepareCheckpoint(String, ExtendedSequenceNumber, String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.ICheckpoint
Record intent to checkpoint for a shard.
prepareCheckpoint() - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will record a pending checkpoint at the last data record that was delivered to the record processor.
prepareCheckpoint(Record) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will record a pending checkpoint at the at the provided record.
prepareCheckpoint(String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will record a pending checkpoint at the provided sequenceNumber.
prepareCheckpoint(String, long) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer
This method will record a pending checkpoint at the provided sequenceNumber and subSequenceNumber, the latter for aggregated records produced with the Producer Library.
PreparedCheckpointer - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Objects of this class are prepared to checkpoint at a specific sequence number.
PreparedCheckpointer(ExtendedSequenceNumber, IRecordProcessorCheckpointer) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PreparedCheckpointer
Constructor.
printUsage(PrintStream, String) - Static method in class com.amazonaws.services.kinesis.multilang.MultiLangDaemon
Utility for describing how to run this app.
prioritize(List<ShardInfo>) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.NoOpShardPrioritization
 
prioritize(List<ShardInfo>) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ParentsFirstShardPrioritization
 
prioritize(List<ShardInfo>) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardPrioritization
Returns new list of shards ordered based on their priority.
processRecords(List<Record>, IRecordProcessorCheckpointer) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor
Process data records.
processRecords(ProcessRecordsInput) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor
Process data records.
processRecords(ProcessRecordsInput) - Method in class com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor
 
ProcessRecordsInput - Class in com.amazonaws.services.kinesis.clientlibrary.types
Container for the parameters to the IRecordProcessor's processRecords method.
ProcessRecordsInput() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
Default constructor.
ProcessRecordsMessage - Class in com.amazonaws.services.kinesis.multilang.messages
A message to indicate to the client's process that it should process a list of records.
ProcessRecordsMessage() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage
Default constructor.
ProcessRecordsMessage(ProcessRecordsInput) - Constructor for class com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage
Convenience constructor.
ProvisionedThroughputException - Exception in com.amazonaws.services.kinesis.leases.exceptions
Indicates that a lease operation has failed due to lack of provisioned throughput for a DynamoDB table.
ProvisionedThroughputException(Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.ProvisionedThroughputException
 
ProvisionedThroughputException(String, Throwable) - Constructor for exception com.amazonaws.services.kinesis.leases.exceptions.ProvisionedThroughputException
 
PROXY_HOST_PROP - Static variable in class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 
PROXY_PORT_PROP - Static variable in class com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig
 
publishMetrics(List<MetricDatumWithKey<CWMetricKey>>) - Method in class com.amazonaws.services.kinesis.metrics.impl.DefaultCWMetricsPublisher
 
publishMetrics(List<MetricDatumWithKey<KeyType>>) - Method in interface com.amazonaws.services.kinesis.metrics.impl.ICWMetricsPublisher
Given a list of MetricDatumWithKey, this method extracts the MetricDatum from each MetricDatumWithKey and publishes those datums.
put(String, String, String, ByteBuffer) - Method in interface com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy
 
put(String, String, String, ByteBuffer) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy
put(String, String, String, ByteBuffer) - Method in class com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator

R

recordProcessorFactory(IRecordProcessorFactory) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker.Builder
Provide a V1 IRecordProcessor.
recordProcessorFactory(IRecordProcessorFactory) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker.Builder
Provide a V2 IRecordProcessor.
RECORDS_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
RecordsFetcherFactory - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
This factory is used to create the records fetcher to retrieve data from Kinesis for a given shard.
registerAllExtensions(ExtensionRegistry) - Static method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages
 
removeRecords(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
removeTags(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
renewLease(T) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Renew a lease by incrementing the lease counter.
renewLease(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Renew a lease by incrementing the lease counter.
renewLeases() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
Attempt to renew all currently held leases.
renewLeases() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
Attempt to renew all currently held leases.
requestShutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
run() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Start consuming data from the stream, and pass it to the application record processors.
run() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
 
runOnce() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
Exposed for testing purposes.
runRenewer() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Runs a single iteration of the lease renewer - used by integration tests.
runTaker() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Runs a single iteration of the lease taker - used by integration tests.

S

safeGetLong(Map<String, AttributeValue>, String) - Static method in class com.amazonaws.services.kinesis.leases.util.DynamoUtils
 
safeGetSS(Map<String, AttributeValue>, String) - Static method in class com.amazonaws.services.kinesis.leases.util.DynamoUtils
 
safeGetString(Map<String, AttributeValue>, String) - Static method in class com.amazonaws.services.kinesis.leases.util.DynamoUtils
 
SentinelCheckpoint - Enum in com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint
Enumeration of the sentinel values of checkpoints.
SequenceNumberValidator - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
This class provides some methods for validating sequence numbers.
serializer - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
 
setCheckpoint(String, ExtendedSequenceNumber, String) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.ICheckpoint
Record a checkpoint for a shard (e.g.
setCheckpoint(ExtendedSequenceNumber) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
Sets checkpoint.
setConcurrencyToken(UUID) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
Sets concurrencyToken.
setData(ByteString) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required bytes data = 3;
setDataFetchingStrategy(DataFetchingStrategy) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory
Sets the dataFetchingStrategy to determine the type of GetRecordsCache to be used.
setDataFetchingStrategy(DataFetchingStrategy) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory
 
setExplicitHashKeyIndex(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
optional uint64 explicit_hash_key_index = 2;
setExplicitHashKeyTable(int, String) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string explicit_hash_key_table = 2;
setIdleMillisBetweenCalls(long) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory
Sets the maximum idle time between two get calls.
setIdleMillisBetweenCalls(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory
 
setKey(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
required string key = 1;
setKeyBytes(ByteString) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
required string key = 1;
setLastCounterIncrementNanos(Long) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
Sets lastCounterIncrementNanos
setLeaseCounter(Long) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
Sets leaseCounter.
setLeaseKey(String) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
Sets leaseKey.
setLeaseOwner(String) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
Sets leaseOwner.
setMaxByteSize(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory
Sets the max byte size for the GetRecordsCache, before further requests are blocked.
setMaxByteSize(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory
 
setMaxPendingProcessRecordsInput(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory
Sets the maximum number of ProcessRecordsInput objects the GetRecordsCache can hold, before further requests are blocked.
setMaxPendingProcessRecordsInput(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory
 
setMaxRecordsCount(int) - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory
Sets the max number of records for the GetRecordsCache can hold, before further requests are blocked.
setMaxRecordsCount(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory
 
setMetricsScope(IMetricsScope) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
Sets given metrics scope for the current thread.
setOwnerSwitchesSinceCheckpoint(Long) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
Sets ownerSwitchesSinceCheckpoint.
setParentShardIds(Collection<String>) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
Sets parentShardIds.
setPartitionKeyIndex(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
required uint64 partition_key_index = 1;
setPartitionKeyTable(int, String) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated string partition_key_table = 1;
setPendingCheckpoint(ExtendedSequenceNumber) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
Sets pending checkpoint.
setReason(String) - Method in class com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage
 
setRecords(int, Messages.Record) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
setRecords(int, Messages.Record.Builder) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord.Builder
repeated .Record records = 3;
setResponseFor(String) - Method in class com.amazonaws.services.kinesis.multilang.messages.StatusMessage
 
setTags(int, Messages.Tag) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
setTags(int, Messages.Tag.Builder) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record.Builder
repeated .Tag tags = 4;
setValue(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
optional string value = 2;
setValueBytes(ByteString) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag.Builder
optional string value = 2;
SHARD_END - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
Special value for SHARD_END.
SHARD_ID_DIMENSION_NAME - Static variable in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
ShardInfo - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Used to pass shard related info among different classes and as a key to the map of shard consumers.
ShardInfo(String, String, Collection<String>, ExtendedSequenceNumber) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
Creates a new ShardInfo object.
ShardPrioritization - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Provides logic to prioritize or filter shards before their execution.
ShardSyncer - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
ShardSyncStrategy - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Facade of methods that can be invoked at different points in KCL application execution to perform certain actions related to shard-sync.
ShardSyncStrategyType - Enum in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Types of ShardSyncStrategy} implemented in KCL.
shouldCallProcessRecordsEvenForEmptyRecordList() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
shouldCleanupLeasesUponShardCompletion() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
shouldIgnoreUnexpectedChildShards() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
shouldValidateSequenceNumberBeforeCheckpointing() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
shutdown(IRecordProcessorCheckpointer, ShutdownReason) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor
Invoked by the Amazon Kinesis Client Library to indicate it will no longer send data records to this RecordProcessor instance.
shutdown(ShutdownInput) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor
Invoked by the Amazon Kinesis Client Library to indicate it will no longer send data records to this RecordProcessor instance.
shutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy
 
shutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.BlockingGetRecordsCache
 
shutdown() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache
This method calls the shutdown behavior on the cache, if available.
shutdown() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetrievalStrategy
Releases any resources used by the strategy.
shutdown() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.LeaderDecider
Can be invoked, if needed, to shutdown any clients/thread-pools being used in the LeaderDecider implementation.
shutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PrefetchGetRecordsCache
 
shutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SynchronousGetRecordsRetrievalStrategy
 
shutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Signals worker to shutdown.
shutdown() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
 
shutdown() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
Shutdown any clients and thread-pools.
shutdown() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory
 
shutdown() - Method in class com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable
 
shutdown(ShutdownInput) - Method in class com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor
 
shutdownComplete() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownNotification
Used to indicate that the record processor has completed the call to IRecordProcessor.shutdown(ShutdownInput) has completed.
ShutdownException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions
The RecordProcessor instance has been shutdown (e.g.
ShutdownException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.ShutdownException
 
ShutdownException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.ShutdownException
 
ShutdownInput - Class in com.amazonaws.services.kinesis.clientlibrary.types
Container for the parameters to the IRecordProcessor's shutdown method.
ShutdownInput() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput
Default constructor.
ShutdownMessage - Class in com.amazonaws.services.kinesis.multilang.messages
A message to indicate to the client's process that it should shutdown and then terminate.
ShutdownMessage() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage
Default constructor.
ShutdownMessage(ShutdownReason) - Constructor for class com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage
Convenience constructor.
ShutdownNotification - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
A shutdown request to the ShardConsumer
shutdownNotificationComplete() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownNotification
Used to indicate that the record processor has been notified of a requested shutdown, and given the chance to checkpoint.
ShutdownReason - Enum in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Reason the RecordProcessor is being shutdown.
shutdownRequested(IRecordProcessorCheckpointer) - Method in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IShutdownNotificationAware
Called when the worker has been requested to shutdown, and gives the record processor a chance to checkpoint.
shutdownRequested(IRecordProcessorCheckpointer) - Method in class com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor
 
ShutdownRequestedMessage - Class in com.amazonaws.services.kinesis.multilang.messages
A message to indicate to the client's process that shutdown is requested.
ShutdownRequestedMessage() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.ShutdownRequestedMessage
Convenience constructor.
SimpleRecordsFetcherFactory - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
SimpleRecordsFetcherFactory() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory
 
size() - Method in class com.amazonaws.services.kinesis.metrics.impl.MetricAccumulatingQueue
 
start() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.BlockingGetRecordsCache
 
start() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache
This method calls the start behavior on the cache, if available.
start() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.PrefetchGetRecordsCache
 
start() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Start background LeaseHolder and LeaseTaker threads.
startGracefulShutdown() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Requests a graceful shutdown of the worker, notifying record processors, that implement IShutdownNotificationAware, of the impending shutdown.
startScope(IMetricsFactory) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
startScope(IMetricsFactory, String) - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
StatusMessage - Class in com.amazonaws.services.kinesis.multilang.messages
A message sent by the client's process to indicate to the record processor that it completed a particular action.
StatusMessage() - Constructor for class com.amazonaws.services.kinesis.multilang.messages.StatusMessage
Default constructor.
StatusMessage(String) - Constructor for class com.amazonaws.services.kinesis.multilang.messages.StatusMessage
Convenience constructor.
stop() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Stops background threads and waits for LeaseCoordinator.STOP_WAIT_TIME_MILLIS for all background tasks to complete.
stopLeaseTaker() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Requests the cancellation of the lease taker.
SUCCESS - Static variable in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
SynchronousGetRecordsRetrievalStrategy - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
SynchronousGetRecordsRetrievalStrategy() - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.SynchronousGetRecordsRetrievalStrategy
 
syncShards() - Method in interface com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategy
Invoked when the KCL application wants to execute shard-sync.

T

table - Variable in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
 
TAGS_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
takeLease(KinesisClientLease, String) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseManager
Take a lease for the given owner by incrementing its leaseCounter and setting its owner field.
takeLease(T, String) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Take a lease for the given owner by incrementing its leaseCounter and setting its owner field.
takeLease(T, String) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Take a lease for the given owner by incrementing its leaseCounter and setting its owner field.
takeLeases() - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseTaker
Compute the set of leases available to be taken and attempt to take them.
takeLeases() - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseTaker
Compute the set of leases available to be taken and attempt to take them.
TaskType - Enum in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Enumerates types of tasks executed as part of processing a shard.
ThreadSafeMetricsDelegatingFactory - Class in com.amazonaws.services.kinesis.metrics.impl
Metrics scope factory that delegates metrics scope creation to another factory, but returns metrics scope that is thread safe.
ThreadSafeMetricsDelegatingFactory(IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingFactory
Creates an instance of the metrics factory.
ThreadSafeMetricsDelegatingScope - Class in com.amazonaws.services.kinesis.metrics.impl
Metrics scope that delegates to another metrics scope and is thread safe to be shared across different threads.
ThreadSafeMetricsDelegatingScope(IMetricsScope) - Constructor for class com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingScope
Creates an instance of the metrics scope.
ThrottlingException - Exception in com.amazonaws.services.kinesis.clientlibrary.exceptions
Thrown when requests are throttled by a service (e.g.
ThrottlingException(String) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.ThrottlingException
 
ThrottlingException(String, Exception) - Constructor for exception com.amazonaws.services.kinesis.clientlibrary.exceptions.ThrottlingException
 
TIME - Static variable in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
 
toBuilder() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
toBuilder() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
toBuilder() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
toDynamoRecord(KinesisClientLease) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer
 
toDynamoRecord(Lease) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseSerializer
 
toDynamoRecord(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer
Construct a DynamoDB record out of a Lease object
toString() - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo
 
toString() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
 
toString() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
 
toString() - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
 
toString() - Method in class com.amazonaws.services.kinesis.multilang.messages.Message
 
TRIM_HORIZON - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber
Special value for TRIM_HORIZON.

U

unsetMetricsScope() - Static method in class com.amazonaws.services.kinesis.metrics.impl.MetricsHelper
Unsets the metrics scope for the current thread.
update(T) - Method in class com.amazonaws.services.kinesis.leases.impl.KinesisClientLease
Updates this Lease's mutable, application-specific fields based on the passed-in lease object.
update(T) - Method in class com.amazonaws.services.kinesis.leases.impl.Lease
Updates this Lease's mutable, application-specific fields based on the passed-in lease object.
updateLease(T, UUID) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
Updates application-specific lease values in DynamoDB.
updateLease(T) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
Update application-specific fields of the given lease in DynamoDB.
updateLease(T, UUID) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseRenewer
Update application-specific fields in a currently held lease.
updateLease(T) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Update application-specific fields of the given lease in DynamoDB.
updateLease(T, UUID) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer
Update application-specific fields in a currently held lease.
UserRecord - Class in com.amazonaws.services.kinesis.clientlibrary.types
This class represents a KPL user record.
UserRecord(Record) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
Create a User Record from a Kinesis Record.
UserRecord(boolean, Record, long, String) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.types.UserRecord
Create a User Record.

V

VALUE_FIELD_NUMBER - Static variable in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint.SentinelCheckpoint
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.DataFetchingStrategy
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategyType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownReason
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.TaskType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.WorkerStateChangeListener.WorkerState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.amazonaws.services.kinesis.metrics.interfaces.MetricsLevel
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint.SentinelCheckpoint
Returns an array containing the constants of this enum type, inthe order they are declared.
values() - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.DataFetchingStrategy
Returns an array containing the constants of this enum type, inthe order they are declared.
values() - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream
Returns an array containing the constants of this enum type, inthe order they are declared.
values() - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategyType
Returns an array containing the constants of this enum type, inthe order they are declared.
values() - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownReason
Returns an array containing the constants of this enum type, inthe order they are declared.
values() - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.TaskType
Returns an array containing the constants of this enum type, inthe order they are declared.
values() - Static method in enum com.amazonaws.services.kinesis.clientlibrary.lib.worker.WorkerStateChangeListener.WorkerState
Returns an array containing the constants of this enum type, inthe order they are declared.
values() - Static method in enum com.amazonaws.services.kinesis.metrics.interfaces.MetricsLevel
Returns an array containing the constants of this enum type, inthe order they are declared.

W

waitUntilLeaseTableExists(long, long) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseManager
 
waitUntilLeaseTableExists(long, long) - Method in interface com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager
Blocks until the lease table exists by polling leaseTableExists.
withCacheEntryTime(Instant) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
 
withCacheExitTime(Instant) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
 
withCallProcessRecordsEvenForEmptyRecordList(boolean) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withCheckpointer(IRecordProcessorCheckpointer) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
Set Checkpointer.
withCheckpointer(IRecordProcessorCheckpointer) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput
Set the checkpointer.
withCleanupLeasesUponShardCompletion(boolean) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withCloudWatchClientConfig(ClientConfiguration) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withCommonClientConfig(ClientConfiguration) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withDataFetchingStrategy(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withDynamoDBClientConfig(ClientConfiguration) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withDynamoDBEndpoint(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withExtendedSequenceNumber(ExtendedSequenceNumber) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput
withFailoverTimeMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withIdleMillisBetweenCalls(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withIdleTimeBetweenReadsInMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Controls how long the KCL will sleep if no records are returned from Kinesis
withIgnoreUnexpectedChildShards(boolean) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withInitialLeaseTableReadCapacity(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withInitialLeaseTableWriteCapacity(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withInitialPositionInStream(InitialPositionInStream) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withKinesisClientConfig(ClientConfiguration) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withKinesisEndpoint(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withListShardsBackoffTimeInMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withLogWarningForTaskAfterMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMaxCacheByteSize(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMaxGetRecordsThreadPool(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMaxLeaseRenewalThreads(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Sets the size of the thread pool that will be used to renew leases.
withMaxLeasesForWorker(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Worker will not acquire more than the specified max number of leases even if there are more shards that need to be processed.
withMaxLeasesForWorker(int) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseTaker
Worker will not acquire more than the specified max number of leases even if there are more shards that need to be processed.
withMaxLeasesToStealAtOneTime(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Max leases to steal from a more loaded Worker at one time (for load balancing).
withMaxLeasesToStealAtOneTime(int) - Method in class com.amazonaws.services.kinesis.leases.impl.LeaseTaker
Max leases to steal from a more loaded Worker at one time (for load balancing).
withMaxListShardsRetryAttempts(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMaxPendingProcessRecordsInput(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMaxRecords(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMaxRecordsCount(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMetricsBufferTimeMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMetricsEnabledDimensions(Set<String>) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Sets the dimensions that are allowed to be emitted in metrics.
withMetricsLevel(MetricsLevel) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMetricsLevel(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Sets metrics level that should be enabled.
withMetricsMaxQueueSize(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withMillisBehindLatest(Long) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
Set milliseconds behind latest.
withParentShardPollIntervalMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withPendingCheckpointSequenceNumber(ExtendedSequenceNumber) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput
Set pending checkpoint ExtendedSequenceNumber.
withRecords(List<Record>) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput
Set records.
withRegionName(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withRetryGetRecordsInSeconds(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withShardId(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput
Set shard Id.
withShardPrioritizationStrategy(ShardPrioritization) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withShardSyncIntervalMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withShardSyncStrategyType(ShardSyncStrategyType) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withShutdownGraceMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withShutdownReason(ShutdownReason) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput
Set shutdown reason.
withSkipShardSyncAtStartupIfLeasesExist(boolean) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
If set to true, the Worker will not sync shards and leases during initialization if there are one or more leases in the lease table.
withTableName(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withTaskBackoffTimeMillis(long) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withTimeoutInSeconds(int) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withTimestampAtInitialPositionInStream(Date) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
withUserAgent(String) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
Override the default user agent (application name).
withValidateSequenceNumberBeforeCheckpointing(boolean) - Method in class com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration
 
Worker - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Worker is the high level class that Kinesis applications use to start processing data.
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, IMetricsFactory) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, IMetricsFactory, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, AmazonKinesis, AmazonDynamoDB, AmazonCloudWatch) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, AmazonKinesis, AmazonDynamoDB, AmazonCloudWatch, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, AmazonKinesisClient, AmazonDynamoDBClient, AmazonCloudWatchClient) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, AmazonKinesisClient, AmazonDynamoDBClient, AmazonCloudWatchClient, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, AmazonKinesisClient, AmazonDynamoDBClient, IMetricsFactory, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker(IRecordProcessorFactory, KinesisClientLibConfiguration, AmazonKinesis, AmazonDynamoDB, IMetricsFactory, ExecutorService) - Constructor for class com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker
Deprecated.
The access to this constructor will be changed in a future release. The recommended way to create a Worker is to use Worker.Builder
Worker.Builder - Class in com.amazonaws.services.kinesis.clientlibrary.lib.worker
Builder to construct a Worker instance.
WORKER_IDENTIFIER_METRIC - Static variable in class com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator
 
WorkerStateChangeListener - Interface in com.amazonaws.services.kinesis.clientlibrary.lib.worker
A listener for callbacks on changes worker state
WorkerStateChangeListener.WorkerState - Enum in com.amazonaws.services.kinesis.clientlibrary.lib.worker
 
writeReplace() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
writeReplace() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
writeReplace() - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
writeTo(CodedOutputStream) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.AggregatedRecord
 
writeTo(CodedOutputStream) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Record
 
writeTo(CodedOutputStream) - Method in class com.amazonaws.services.kinesis.clientlibrary.types.Messages.Tag
 
A B C D E F G H I J K L M N O P R S T U V W 

Copyright © 2019. All rights reserved.



NOTHING
NOTHING
Add the Maven Dependecy to your project: maven dependecy for com.amazonaws : aws-java-sdk : 1.3.14