path # lines of code number of updates days since first update days since last update first updated last updated amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/WorkerStateChangeListener.java 14 4 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/GracefulShutdownCoordinator.java 104 5 1279 230 2018-08-02 2021-06-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/RejectedTaskEvent.java 27 2 949 900 2019-06-28 2019-08-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/GracefulShutdownContext.java 15 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/DiagnosticEvent.java 5 1 949 949 2019-06-28 2019-06-28 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/CoordinatorConfig.java 21 5 1279 775 2018-08-02 2019-12-19 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/NoOpWorkerStateChangeListener.java 8 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/DeterministicShuffleShardSyncLeaderDecider.java 109 2 533 305 2020-08-17 2021-04-02 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/DiagnosticEventHandler.java 5 1 949 949 2019-06-28 2019-06-28 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/LeaderDecider.java 5 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/DiagnosticEventLogger.java 24 1 949 949 2019-06-28 2019-06-28 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/ExecutorStateEvent.java 49 2 949 533 2019-06-28 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java 753 25 1279 159 2018-08-02 2021-08-26 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/PeriodicShardSyncManager.java 355 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/CoordinatorFactory.java 17 4 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/DiagnosticEventFactory.java 13 1 949 949 2019-06-28 2019-06-28 amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/SchedulerCoordinatorFactory.java 34 5 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseSerializer.java 32 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/DynamoUtils.java 67 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java 187 12 1279 118 2018-08-02 2021-10-06 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseRenewer.java 18 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardPrioritization.java 5 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java 576 4 1210 533 2018-10-10 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/MultiStreamLease.java 44 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/Lease.java 143 4 1279 411 2018-08-02 2020-12-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardSyncTaskManager.java 154 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardSyncTask.java 60 5 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/UpdateField.java 4 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ParentsFirstShardPrioritization.java 93 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardDetector.java 26 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCoordinator.java 31 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseTaker.java 13 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/NoOpShardPrioritization.java 11 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseSerializer.java 243 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRenewer.java 273 6 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/TableCreatorCallbackInput.java 19 2 1225 1033 2018-09-25 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseRefresher.java 545 10 1279 118 2018-08-02 2021-10-06 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBMultiStreamLeaseSerializer.java 38 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/TableConstants.java 9 3 1271 1033 2018-08-10 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java 393 10 1279 29 2018-08-02 2022-01-03 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseManagementFactory.java 294 12 1279 118 2018-08-02 2021-10-06 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/TableCreatorCallback.java 7 2 1225 1033 2018-09-25 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseCoordinator.java 292 11 1279 40 2018-08-02 2021-12-23 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseRefresher.java 39 5 1279 118 2018-08-02 2021-10-06 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardInfo.java 79 5 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/exceptions/LeasingException.java 13 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/exceptions/ShardSyncer.java 21 2 1210 533 2018-10-10 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/exceptions/ProvisionedThroughputException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/exceptions/CustomerApplicationException.java 6 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/exceptions/InvalidStateException.java 13 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/exceptions/LeasePendingDeletion.java 24 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/exceptions/DependencyException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/KinesisShardDetector.java 237 8 1279 347 2018-08-02 2021-02-19 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementFactory.java 17 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseCleanupManager.java 275 2 533 215 2020-08-17 2021-07-01 amazon-kinesis-client/src/main/java/software/amazon/kinesis/schemaregistry/SchemaRegistryDecoder.java 55 3 461 124 2020-10-28 2021-09-30 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/DataRetrievalUtil.java 20 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/kpl/ExtendedSequenceNumber.java 129 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/kpl/Messages.java 2123 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/DataFetcherResult.java 7 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RecordsPublisher.java 15 5 1279 715 2018-08-02 2020-02-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetrievalFactory.java 12 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetrievalConfig.java 103 48 1279 28 2018-08-02 2022-01-04 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/KinesisClientRecord.java 32 4 1279 439 2018-08-02 2020-11-19 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/DataFetcherProviderConfig.java 11 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/IteratorBuilder.java 71 3 1279 1265 2018-08-02 2018-08-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RecordsRetrieved.java 8 3 1090 900 2019-02-07 2019-08-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/ThrottlingReporter.java 27 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RecordsFetcherFactory.java 16 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/BatchUniqueIdentifier.java 9 1 900 900 2019-08-16 2019-08-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/AWSExceptionManager.java 36 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/AggregatorUtil.java 153 4 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetryableRetrievalException.java 10 2 1231 1033 2018-09-19 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/GetRecordsRetriever.java 5 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RetrievalSpecificConfig.java 6 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/DataFetchingStrategy.java 4 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/GetRecordsRetrievalStrategy.java 17 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutRetrievalFactory.java 54 7 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutConsumerRegistration.java 183 7 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutConfig.java 47 7 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/FanOutRecordsPublisher.java 809 22 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/fanout/MultipleSubscriberException.java 3 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/ConsumerRegistration.java 5 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/KinesisDataFetcherProviderConfig.java 19 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/AsynchronousGetRecordsRetrievalStrategy.java 111 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/SynchronousBlockingRetrievalFactory.java 88 5 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/BlockingRecordsPublisher.java 62 6 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/DataFetcher.java 28 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PollingConfig.java 55 5 1279 405 2018-08-02 2020-12-23 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/SimpleRecordsFetcherFactory.java 70 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/SynchronousPrefetchingRetrievalFactory.java 68 5 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/SynchronousGetRecordsRetrievalStrategy.java 32 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java 453 19 1279 117 2018-08-02 2021-10-07 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/KinesisDataFetcher.java 266 8 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/RecordsDeliveryAck.java 4 1 900 900 2019-08-16 2019-08-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/HashKeyRangeForLease.java 34 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/InitialPositionInStream.java 6 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/CommonCalculations.java 6 1 411 411 2020-12-17 2020-12-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/KinesisRequestsBuilder.java 46 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/FutureUtils.java 17 2 1051 1033 2019-03-18 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/StreamIdentifier.java 48 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/RequestDetails.java 27 2 715 533 2020-02-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/InitialPositionInStreamExtended.java 35 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/KinesisClientUtil.java 20 6 1279 657 2018-08-02 2020-04-15 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/StreamConfig.java 10 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/DiagnosticUtils.java 23 2 900 533 2019-08-16 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/LeaseCleanupConfig.java 12 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/ConfigsBuilder.java 101 5 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/annotations/KinesisClientInternalApi.java 6 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardRecordProcessorCheckpointer.java 201 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/SequenceNumberValidator.java 58 3 1233 1033 2018-09-17 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/SentinelCheckpoint.java 7 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/DoesNothingPreparedCheckpointer.java 24 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/ShardPreparedCheckpointer.java 28 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/CheckpointFactory.java 7 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/Checkpoint.java 23 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/dynamodb/DynamoDBCheckpointFactory.java 16 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/dynamodb/DynamoDBCheckpointer.java 131 5 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/checkpoint/CheckpointConfig.java 9 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/MultiStreamTracker.java 12 2 533 159 2020-08-17 2021-08-26 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/ShardRecordProcessorFactory.java 8 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/ProcessorConfig.java 11 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/Checkpointer.java 16 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/PreparedCheckpointer.java 12 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/FormerStreamsLeasesDeletionStrategy.java 44 1 533 533 2020-08-17 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/ShutdownNotificationAware.java 4 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/ShardRecordProcessor.java 13 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/processor/RecordProcessorCheckpointer.java 39 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/KinesisClientLibRetryableException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/ShutdownException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/KinesisClientLibException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/KinesisClientLibNonRetryableException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/KinesisClientLibDependencyException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/InvalidStateException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/internal/BlockedOnParentShardException.java 11 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/internal/KinesisClientLibIOException.java 11 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/exceptions/ThrottlingException.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/CloudWatchMetricsFactory.java 37 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/CloudWatchMetricsPublisher.java 59 3 1279 907 2018-08-02 2019-08-09 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/LogMetricsScope.java 32 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/EndingMetricsScope.java 31 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/AccumulateByNameMetricsScope.java 7 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricsScope.java 9 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/LogMetricsFactory.java 7 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/CloudWatchMetricsScope.java 21 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/ThreadSafeMetricsDelegatingFactory.java 11 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/ThreadSafeMetricsDelegatingScope.java 24 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/FilteringMetricsScope.java 37 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/AccumulatingMetricsScope.java 40 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricsConfig.java 30 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/CloudWatchPublisherRunnable.java 125 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/NullMetricsFactory.java 8 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/CloudWatchMetricKey.java 28 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricsFactory.java 4 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricDatumWithKey.java 29 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/NullMetricsScope.java 16 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricAccumulatingQueue.java 57 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricsUtil.java 71 5 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/InterceptingMetricsFactory.java 50 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/DimensionTrackingMetricsScope.java 14 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricsLevel.java 24 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/metrics/MetricsCollectingTaskDecorator.java 39 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownInput.java 17 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/events/ShardEndedInput.java 16 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/events/InitializationInput.java 19 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/events/LeaseLostInput.java 14 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/events/TaskExecutionListenerInput.java 16 2 1210 1033 2018-10-10 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/events/ShutdownRequestedInput.java 16 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/events/ProcessRecordsInput.java 33 3 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumer.java 355 11 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/LifecycleConfig.java 15 6 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerTask.java 6 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerArgument.java 60 9 1279 439 2018-08-02 2020-11-19 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java 220 10 1279 57 2018-08-02 2021-12-06 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/TaskExecutionListener.java 6 2 1210 1033 2018-10-10 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownReason.java 25 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/TaskType.java 10 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownNotification.java 6 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerShutdownNotification.java 44 3 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/NoOpTaskExecutionListener.java 10 2 1210 1033 2018-10-10 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerNotifyingSubscriber.java 25 1 900 900 2019-08-16 2019-08-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerState.java 19 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/BlockOnParentShardTask.java 63 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/TaskResult.java 24 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/NotifyingSubscriber.java 28 1 900 900 2019-08-16 2019-08-16 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java 273 7 1279 439 2018-08-02 2020-11-19 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/InitializeTask.java 96 4 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java 247 6 1279 533 2018-08-02 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownNotificationTask.java 35 2 1279 1033 2018-08-02 2019-04-05 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriber.java 179 8 1090 533 2019-02-07 2020-08-17 amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/TaskOutcome.java 6 2 1210 1033 2018-10-10 2019-04-05 amazon-kinesis-client/src/main/java-templates/KinesisClientLibraryPackage.java 4 1 124 124 2021-09-30 2021-09-30 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/coordinator/KinesisClientLibConfiguration.java 571 5 1279 775 2018-08-02 2019-12-19 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/GetNextMessageTask.java 41 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/MultiLangDaemon.java 161 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/MultiLangProtocol.java 155 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/package-info.java 1 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/MessageReader.java 43 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/BuilderDynaBean.java 223 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/KinesisClientLibConfigurator.java 51 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/IntegerPropertyValueDecoder.java 15 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/DynaBeanBuilderSupport.java 204 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/MultiLangDaemonConfiguration.java 317 5 1113 245 2019-01-15 2021-06-01 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/TypeTag.java 9 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/AWSCredentialsProviderPropertyValueDecoder.java 74 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/ConfigurationSettableUtils.java 81 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/ConfigurationSettable.java 14 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/ConfigurationSettables.java 10 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/credentials/V2CredentialWrapper.java 29 3 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/IPropertyValueDecoder.java 6 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/DatePropertyValueDecoder.java 20 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/RetrievalMode.java 39 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/FanoutConfigBean.java 26 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/PollingConfigBean.java 34 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/RetrievalConfigBuilder.java 6 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/DynaBeanBuilderUtils.java 30 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/config/DynaBeanCreateSupport.java 73 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/Message.java 32 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/ShutdownRequestedMessage.java 6 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/ShardEndedMessage.java 4 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/ShutdownMessage.java 17 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/JsonFriendlyRecord.java 43 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/LeaseLostMessage.java 4 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/ProcessRecordsMessage.java 24 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/InitializeMessage.java 24 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/StatusMessage.java 13 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/messages/CheckpointMessage.java 20 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/MultiLangRecordProcessorFactory.java 38 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/MultiLangShardRecordProcessor.java 181 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/LineReaderTask.java 71 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/MultiLangDaemonConfig.java 122 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/DrainChildSTDERRTask.java 25 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/MessageWriter.java 111 2 1113 1033 2019-01-15 2019-04-05 amazon-kinesis-client-multilang/src/main/java/software/amazon/kinesis/multilang/DrainChildSTDOUTTask.java 25 2 1113 1033 2019-01-15 2019-04-05