Path	Lines of Code
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/FlinkKinesisConsumerTest.java	740
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/FlinkKinesisProducerTest.java	331
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/KinesisConsumerTest.java	39
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/DynamoDBStreamsDataFetcherTest.java	40
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcherTest.java	796
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/ShardConsumerFanOutTest.java	191
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/ShardConsumerTest.java	145
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/ShardConsumerTestUtils.java	143
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/RecordBatchTest.java	58
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/FanOutRecordPublisherConfigurationTest.java	132
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/FanOutRecordPublisherTest.java	352
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/FanOutShardSubscriberTest.java	87
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/StreamConsumerRegistrarTest.java	213
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherConfigurationTest.java	41
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherFactoryTest.java	38
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherTest.java	114
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/manualtests/ManualConsumerProducerTest.java	80
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/manualtests/ManualExactlyOnceTest.java	102
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/manualtests/ManualExactlyOnceWithStreamReshardingTest.java	178
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/manualtests/ManualProducerTest.java	52
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/metrics/PollingRecordPublisherMetricsReporterTest.java	42
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/metrics/ShardConsumerMetricsReporterTest.java	50
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/model/DynamoDBStreamsShardHandleTest.java	61
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/model/SentinelSequenceNumberTest.java	11
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/model/StartingPositionTest.java	62
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/model/StreamShardHandleTest.java	14
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxyTest.java	357
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxyV2FactoryTest.java	63
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxyV2Test.java	261
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicTableFactoryTest.java	233
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/table/RowDataFieldsKinesisPartitionerTest.java	204
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/AlwaysThrowsDeserializationSchema.java	27
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/ExactlyOnceValidatingConsumerThread.java	115
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/FakeKinesisBehavioursFactory.java	433
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/FakeKinesisFanOutBehavioursFactory.java	474
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/KinesisEventsGeneratorProducerThread.java	80
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/KinesisPubsubClient.java	90
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/KinesisShardIdGenerator.java	6
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TableOptionsBuilder.java	34
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TestFormatFactory.java	154
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TestRuntimeContext.java	57
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TestSourceContext.java	35
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TestUtils.java	117
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TestableFlinkKinesisConsumer.java	34
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TestableKinesisDataFetcher.java	130
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/testutils/TestableKinesisDataFetcherForShardConsumerException.java	59
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/util/AWSUtilTest.java	164
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/util/AwsV2UtilTest.java	403
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/util/JobManagerWatermarkTrackerTest.java	64
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/util/KinesisConfigUtilTest.java	647
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/util/RecordEmitterTest.java	88
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/util/StreamConsumerRegistrarUtilTest.java	58
amazon-kinesis-connector-flink/src/test/java/software/amazon/kinesis/connectors/flink/util/WatermarkTrackerTest.java	65