Path	Lines of Code
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FixedKinesisPartitioner.java	40
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkDynamoDBStreamsConsumer.java	41
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkKinesisConsumer.java	248
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkKinesisException.java	17
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkKinesisProducer.java	247
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/KinesisPartitioner.java	13
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/KinesisShardAssigner.java	8
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/RandomKinesisPartitioner.java	18
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config/AWSConfigConstants.java	54
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config/ConsumerConfigConstants.java	134
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config/ProducerConfigConstants.java	9
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/DynamoDBStreamsDataFetcher.java	69
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java	796
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/ShardConsumer.java	134
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/RecordBatch.java	50
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/RecordPublisher.java	15
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/RecordPublisherFactory.java	16
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/FanOutRecordPublisher.java	160
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java	221
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/FanOutRecordPublisherFactory.java	43
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/FanOutShardSubscriber.java	318
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout/StreamConsumerRegistrar.java	176
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/AdaptivePollingRecordPublisher.java	55
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisher.java	114
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherConfiguration.java	30
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherFactory.java	50
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics/KinesisConsumerMetricConstants.java	17
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics/PollingRecordPublisherMetricsReporter.java	49
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics/ShardConsumerMetricsReporter.java	49
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/DynamoDBStreamsShardHandle.java	23
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/KinesisStreamShard.java	67
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/KinesisStreamShardState.java	54
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/SentinelSequenceNumber.java	26
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/SequenceNumber.java	53
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/StartingPosition.java	55
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/StreamShardHandle.java	51
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/StreamShardMetadata.java	156
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/DynamoDBStreamsProxy.java	83
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/FullJitterBackoff.java	14
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/GetShardListResult.java	46
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxy.java	341
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxyInterface.java	11
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxyV2.java	145
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxyV2Factory.java	30
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy/KinesisProxyV2Interface.java	21
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization/DynamoDBStreamsSchema.java	18
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization/KinesisDeserializationSchema.java	12
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization/KinesisDeserializationSchemaWrapper.java	37
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization/KinesisSerializationSchema.java	12
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSink.java	110
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSource.java	90
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicTableFactory.java	104
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisOptions.java	165
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/RowDataFieldsKinesisPartitioner.java	168
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/RowDataKinesisDeserializationSchema.java	39
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/AWSUtil.java	172
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/AwsV2Util.java	218
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/BeanDeserializerModifierForIgnorables.java	46
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/JobManagerWatermarkTracker.java	130
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/KinesisConfigUtil.java	347
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/RecordEmitter.java	169
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/StreamConsumerRegistrarUtil.java	101
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/TimeoutLatch.java	21
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/WatermarkTracker.java	48