org.apache.beam.sdk.io.kinesis.BasicKinesisClientProviderTest ‑ testSerialization
org.apache.beam.sdk.io.kinesis.CustomOptionalTest ‑ absentThrowsNoSuchElementExceptionOnGet
org.apache.beam.sdk.io.kinesis.CustomOptionalTest ‑ testEqualsAndHashCode
org.apache.beam.sdk.io.kinesis.DynamicCheckpointGeneratorTest ‑ shouldMapAllShardsToCheckpoints
org.apache.beam.sdk.io.kinesis.KinesisIOIT ‑ testWriteThenRead
org.apache.beam.sdk.io.kinesis.KinesisIOReadTest ‑ testReadWithBasicCredentials
org.apache.beam.sdk.io.kinesis.KinesisIOReadTest ‑ testReadWithBasicCredentialsAndCustomEndpoint
org.apache.beam.sdk.io.kinesis.KinesisIOReadTest ‑ testReadWithBasicCredentialsAndVerificationDisabled
org.apache.beam.sdk.io.kinesis.KinesisIOReadTest ‑ testReadWithCredentialsProvider
org.apache.beam.sdk.io.kinesis.KinesisIOReadTest ‑ testReadWithCredentialsProviderAndCustomEndpoint
org.apache.beam.sdk.io.kinesis.KinesisIOReadTest ‑ testReadWithCredentialsProviderAndVerificationDisabled
org.apache.beam.sdk.io.kinesis.KinesisIOWriteTest ‑ testReadWithBasicCredentials
org.apache.beam.sdk.io.kinesis.KinesisIOWriteTest ‑ testReadWithBasicCredentialsAndCustomEndpoint
org.apache.beam.sdk.io.kinesis.KinesisIOWriteTest ‑ testReadWithBasicCredentialsAndVerificationDisabled
org.apache.beam.sdk.io.kinesis.KinesisIOWriteTest ‑ testReadWithCredentialsProvider
org.apache.beam.sdk.io.kinesis.KinesisIOWriteTest ‑ testReadWithCredentialsProviderAndCustomEndpoint
org.apache.beam.sdk.io.kinesis.KinesisIOWriteTest ‑ testReadWithCredentialsProviderAndVerificationDisabled
org.apache.beam.sdk.io.kinesis.KinesisMockReadTest ‑ readsDataFromMockKinesis
org.apache.beam.sdk.io.kinesis.KinesisMockReadTest ‑ readsDataFromMockKinesisWithLimitFailure
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testSetInvalidProperty
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWrite
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWriteAndReadFromMockKinesis
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWriteBuildsCorrectly
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWriteFailed
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWriteValidationFailsMissingAWSClientsProvider
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWriteValidationFailsMissingPartitioner
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWriteValidationFailsMissingStreamName
org.apache.beam.sdk.io.kinesis.KinesisMockWriteTest ‑ testWriteValidationFailsPartitionerAndPartitioneKey
org.apache.beam.sdk.io.kinesis.KinesisReaderCheckpointTest ‑ isImmutable
org.apache.beam.sdk.io.kinesis.KinesisReaderCheckpointTest ‑ splitsCheckpointAccordingly
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ getSplitBacklogBytesShouldReturnBacklogUnknown
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ getSplitBacklogBytesShouldReturnLastSeenValueWhenCalledFrequently
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ getSplitBacklogBytesShouldReturnLastSeenValueWhenKinesisExceptionsOccur
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ readsThroughAllDataAvailable
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ returnsCurrentWatermark
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ startReturnsFalseIfNoDataAtTheBeginning
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ startReturnsTrueIfSomeDataAvailable
org.apache.beam.sdk.io.kinesis.KinesisReaderTest ‑ throwsNoSuchElementExceptionIfNoData
org.apache.beam.sdk.io.kinesis.KinesisRecordCoderTest ‑ encodingAndDecodingWorks
org.apache.beam.sdk.io.kinesis.RateLimitPolicyFactoryTest ‑ defaultRateLimiterShouldUseBackoffs
org.apache.beam.sdk.io.kinesis.RateLimitPolicyFactoryTest ‑ shouldDelayDefaultInterval
org.apache.beam.sdk.io.kinesis.RateLimitPolicyFactoryTest ‑ shouldDelayDynamicInterval
org.apache.beam.sdk.io.kinesis.RateLimitPolicyFactoryTest ‑ shouldDelayFixedInterval
org.apache.beam.sdk.io.kinesis.RateLimitPolicyFactoryTest ‑ withoutLimiterShouldDoNothing
org.apache.beam.sdk.io.kinesis.RecordFilterTest ‑ shouldFilterOutRecordsBeforeOrAtCheckpoint
org.apache.beam.sdk.io.kinesis.RecordFilterTest ‑ shouldNotFailOnEmptyList
org.apache.beam.sdk.io.kinesis.ShardCheckpointTest ‑ testComparisonWithExtendedSequenceNumber
org.apache.beam.sdk.io.kinesis.ShardCheckpointTest ‑ testComparisonWithTimestamp
org.apache.beam.sdk.io.kinesis.ShardCheckpointTest ‑ testProvidingShardIterator
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldCallRateLimitPolicy
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldCheckpointReadRecords
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldForgetClosedShardIterator
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldInterruptKinesisReadingAndStopShortly
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldInterruptPuttingRecordsToQueueAndStopShortly
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldReturnAbsentOptionalWhenNoRecords
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldReturnAbsentOptionalWhenStartedWithNoIterators
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldReturnAllRecords
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldReturnTheLeastWatermarkOfAllShards
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldReturnTheOldestFromLatestRecordTimestampOfAllShards
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldStartReadingSuccessiveShardsAfterReceivingShardClosedException
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldStopReadersPoolWhenLastShardReaderStopped
org.apache.beam.sdk.io.kinesis.ShardReadersPoolTest ‑ shouldStopReadingShardAfterReceivingShardClosedException
org.apache.beam.sdk.io.kinesis.ShardRecordsIteratorTest ‑ conformingRecordsMovesCheckpoint
org.apache.beam.sdk.io.kinesis.ShardRecordsIteratorTest ‑ goesThroughAvailableRecords
org.apache.beam.sdk.io.kinesis.ShardRecordsIteratorTest ‑ refreshesExpiredIterator
org.apache.beam.sdk.io.kinesis.ShardRecordsIteratorTest ‑ tracksLatestRecordTimestamp
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldCountBytesWhenMultipleDataPointsReturned
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldCountBytesWhenSingleDataPointReturned
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleClientErrorForGetBacklogBytes
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleClientErrorForGetShardIterator
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleClientErrorForShardListing
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleExpiredIterationExceptionForGetShardIterator
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleExpiredIterationExceptionForShardListing
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleLimitExceededExceptionForGetBacklogBytes
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleLimitExceededExceptionForGetShardIterator
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleLimitExceededExceptionForShardListing
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleProvisionedThroughputExceededExceptionForGetBacklogBytes
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleProvisionedThroughputExceededExceptionForGetShardIterator
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleProvisionedThroughputExceededExceptionForShardListing
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleServiceErrorForGetBacklogBytes
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleServiceErrorForGetShardIterator
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleServiceErrorForShardListing
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleUnexpectedExceptionForGetBacklogBytes
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleUnexpectedExceptionForGetShardIterator
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldHandleUnexpectedExceptionForShardListing
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForExclusiveStartShardId
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForLatest
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForTimestampBeforeStreamCreationTimestamp
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForTimestampOutsideStreamRetentionAfterStreamCreationTimestamp
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForTimestampWithRetriedDescribeStreamSummaryCallAfterStreamCreationTimestamp
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForTimestampWithinStreamRetentionAfterStreamCreationTimestamp
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForTrimHorizon
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldListAllShardsForTrimHorizonWithPagedResults
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldNotCallCloudWatchWhenSpecifiedPeriodTooShort
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldReturnIteratorStartingWithSequenceNumber
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldReturnIteratorStartingWithTimestamp
org.apache.beam.sdk.io.kinesis.SimplifiedKinesisClientTest ‑ shouldReturnLimitedNumberOfRecords
org.apache.beam.sdk.io.kinesis.WatermarkPolicyTest ‑ shouldAdvanceWatermarkToNowWithProcessingTimePolicy
org.apache.beam.sdk.io.kinesis.WatermarkPolicyTest ‑ shouldAdvanceWatermarkWhenThereAreNoIncomingRecords
org.apache.beam.sdk.io.kinesis.WatermarkPolicyTest ‑ shouldAdvanceWatermarkWithCustomTimePolicy
org.apache.beam.sdk.io.kinesis.WatermarkPolicyTest ‑ shouldAdvanceWatermarkWithTheArrivalTimeFromKinesisRecords
org.apache.beam.sdk.io.kinesis.WatermarkPolicyTest ‑ shouldOnlyAdvanceTheWatermark
org.apache.beam.sdk.io.kinesis.WatermarkPolicyTest ‑ shouldUpdateWatermarkParameters
org.apache.beam.sdk.io.kinesis.serde.AwsModuleTest ‑ testAWSStaticCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.kinesis.serde.AwsModuleTest ‑ testClasspathPropertiesFileCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.kinesis.serde.AwsModuleTest ‑ testObjectMapperCannotFindModule
org.apache.beam.sdk.io.kinesis.serde.AwsModuleTest ‑ testPropertiesFileCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.kinesis.serde.AwsModuleTest ‑ testSingletonAWSCredentialsProviderSerializationDeserialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testBasicCredentialsProviderSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testClasspathPropertiesFileCredentialsProviderSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testDefaultAWSCredentialsProviderChainSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testEC2ContainerCredentialsProviderWrapperSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testEnvironmentVariableCredentialsProviderSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testFailOnAWSCredentialsProviderDeserialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testFailOnAWSCredentialsProviderSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testProfileCredentialsProviderSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testPropertiesFileCredentialsProviderSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testStaticSessionCredentialsProviderSerialization
org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtilsTest ‑ testSystemPropertiesCredentialsProviderSerialization