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