amazon-kinesis-client:Amazon Kinesis的客户端库
需积分: 9 150 浏览量
2021-05-12
06:05:17
上传
评论
收藏 704KB ZIP 举报
amazon-kinesis-client:Amazon Kinesis的客户端库 （336个子文件） 
.gitignore 47B HierarchicalShardSyncerTest.java 150KB WorkerTest.java 94KB Messages.java 87KB FanOutRecordsPublisherTest.java 79KB SchedulerTest.java 62KB KinesisClientLibConfiguration.java 62KB Scheduler.java 54KB HierarchicalShardSyncer.java 53KB FanOutRecordsPublisher.java 47KB ShardShardRecordProcessorCheckpointerTest.java 45KB ShardConsumerTest.java 40KB BuilderDynaBeanTest.java 37KB ProcessTaskTest.java 35KB ShardConsumerSubscriberTest.java 34KB DynamoDBLeaseRefresher.java 33KB PrefetchRecordsPublisherTest.java 33KB PeriodicShardSyncManagerTest.java 29KB DynamoDBLeaseManagementFactory.java 28KB KinesisDataFetcherTest.java 27KB PrefetchRecordsPublisher.java 27KB DynamoDBLeaseTaker.java 25KB ShutdownTaskTest.java 25KB RecordProcessorCheckpointer.java 24KB ConsumerStatesTest.java 24KB PeriodicShardSyncManager.java 23KB ConsumerStates.java 23KB KinesisClientLibConfiguratorTest.java 19KB ShardConsumer.java 19KB DynamoDBLeaseRenewer.java 18KB MultiLangDaemonConfiguration.java 17KB DynamoDBLeaseCoordinator.java 17KB ShardRecordProcessorCheckpointer.java 17KB KinesisClientLibConfigurationTest.java 16KB ShutdownTask.java 16KB LeaseCleanupManager.java 16KB DynamoDBLeaseSerializer.java 15KB LeaseManagementConfig.java 15KB KinesisDataFetcher.java 15KB ProcessTask.java 15KB DynamoDBLeaseRefresherTest.java 14KB LeaseCleanupManagerTest.java 14KB MultiLangProtocol.java 13KB KinesisShardDetector.java 13KB GracefulShutdownCoordinatorTest.java 13KB MultiLangShardRecordProcessor.java 13KB StreamingShardRecordProcessorTest.java 13KB DynamoDBLeaseRefresherIntegrationTest.java 12KB FanOutConsumerRegistrationTest.java 12KB BlockOnParentShardTaskTest.java 12KB PrefetchRecordsPublisherIntegrationTest.java 12KB MultiLangProtocolTest.java 12KB CheckpointerTest.java 11KB Lease.java 11KB DynamoDBLeaseCoordinatorIntegrationTest.java 11KB DynamoDBLeaseRenewerBillingModePayPerRequestIntegrationTest.java 11KB AggregatorUtil.java 11KB DynamoDBLeaseRenewerIntegrationTest.java 11KB LeaseRefresher.java 11KB MultiLangDaemonTest.java 10KB BuilderDynaBean.java 10KB ShardSyncTaskManager.java 10KB FanOutConsumerRegistration.java 10KB KinesisShardDetectorTest.java 10KB LeaseCoordinatorExerciser.java 10KB ExtendedSequenceNumber.java 9KB DynaBeanBuilderSupport.java 9KB MultiLangDaemon.java 9KB MessageWriter.java 9KB MultiLangDaemonConfig.java 9KB IteratorBuilderTest.java 9KB ShardConsumerSubscriber.java 9KB ExceptionThrowingLeaseRefresher.java 8KB FanOutConfigTest.java 8KB DeterministicShuffleShardSyncLeaderDecider.java 8KB AsynchronousGetRecordsRetrievalStrategyTest.java 8KB DynamoDBLeaseTakerIntegrationTest.java 8KB MessageReaderTest.java 8KB MultiLangDaemonConfigurationTest.java 8KB AsynchronousGetRecordsRetrievalStrategyIntegrationTest.java 8KB ParentsFirstShardPrioritizationUnitTest.java 8KB SequenceNumberValidator.java 8KB ConfigsBuilder.java 8KB DynamoDBCheckpointer.java 7KB RetrievalConfig.java 7KB GracefulShutdownCoordinator.java 7KB MessageWriterTest.java 7KB CloudWatchPublisherRunnable.java 7KB ConfigurationSettableUtilsTest.java 7KB DiagnosticEventsTest.java 7KB DeterministicShuffleShardSyncLeaderDeciderTest.java 7KB TestStreamlet.java 6KB LineReaderTask.java 6KB CloudWatchPublisherRunnableTest.java 6KB JsonFriendlyRecordTest.java 6KB AsynchronousGetRecordsRetrievalStrategy.java 6KB ShardInfo.java 6KB ShardSyncTaskIntegrationTest.java 6KB AWSCredentialsProviderPropertyValueDecoderTest.java 6KB TestHarnessBuilder.java 6KB共 336 条
- 1
- 2
- 3
- 4
资源评论
