awslabs / amazon-kinesis-connector-flink
File Age

File age measurements show the distribution of file ages (days since the first commit) and the recency of file updates (days since the latest commit).

Summary
  • Number of files: 64
  • Daily file updates (only one update per file and date counted): 264
  • First update: 2020-10-01
  • Latest update: 2022-01-04
  • Days between first and latest update: 461 (65 weeks, estimated 325 working days)
  • Active days (at least one file change): 33
  • Data:
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 64 files with 6,374 lines of code in files.
    • 0 files that are 366+ days old (0 lines of code)
    • 64 files that are 181-365 days old (6,374 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
0% | 100% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30
Latest Change Distribution Overall
Days since last update
  • There are 64 files with 6,374 lines of code in files.
    • 0 files have been last changed 366+ days ago (0 lines of code)
    • 61 files have been last changed 181-365 days ago (6,090 lines of code)
    • 3 files have been last changed 91-180 days ago (284 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
0% | 95% | 4% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30
File Change History per File Extension
java, xml, md, txt, gitignore, json, properties
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java0% | 100% | 0% | 0% | 0%
Latest Change Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java0% | 95% | 4% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink/util0% | 100% | 0% | 0% | 0%
flink/internals/publisher0% | 100% | 0% | 0% | 0%
flink/internals0% | 100% | 0% | 0% | 0%
flink/proxy0% | 100% | 0% | 0% | 0%
flink/table0% | 100% | 0% | 0% | 0%
flink0% | 100% | 0% | 0% | 0%
flink/model0% | 100% | 0% | 0% | 0%
flink/config0% | 100% | 0% | 0% | 0%
flink/metrics0% | 100% | 0% | 0% | 0%
flink/serialization0% | 100% | 0% | 0% | 0%
primary (latest change distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink/internals/publisher0% | 100% | 0% | 0% | 0%
flink/util0% | 91% | 8% | 0% | 0%
flink/internals0% | 86% | 13% | 0% | 0%
flink/proxy0% | 100% | 0% | 0% | 0%
flink/table0% | 100% | 0% | 0% | 0%
flink0% | 100% | 0% | 0% | 0%
flink/model0% | 100% | 0% | 0% | 0%
flink/config0% | 100% | 0% | 0% | 0%
flink/serialization0% | 100% | 0% | 0% | 0%
flink/metrics0% | 57% | 42% | 0% | 0%
Oldest Files (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
KinesisDataFetcher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals
796 44 287 287 1
KinesisConfigUtil.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
347 13 287 287 1
KinesisProxy.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
341 12 287 287 1
FanOutShardSubscriber.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
318 27 183 287 2
FlinkKinesisConsumer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
248 17 287 287 1
FlinkKinesisProducer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
247 16 231 287 2
FanOutRecordPublisherConfiguration.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
221 27 287 287 1
AwsV2Util.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
218 15 183 287 2
StreamConsumerRegistrar.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
176 15 287 287 1
AWSUtil.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
172 9 287 287 1
RecordEmitter.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
169 13 287 287 1
RowDataFieldsKinesisPartitioner.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table
168 9 287 287 1
KinesisOptions.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table
165 8 287 287 1
FanOutRecordPublisher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
160 5 183 287 2
StreamShardMetadata.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model
156 23 287 287 1
KinesisProxyV2.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
145 10 287 287 1
ConsumerConfigConstants.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config
134 2 183 287 2
ShardConsumer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals
134 7 174 287 2
JobManagerWatermarkTracker.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
130 8 287 287 1
PollingRecordPublisher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling
114 6 287 287 1
Files Not Recently Changed (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
KinesisShardAssigner.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
8 - 287 287 1
ProducerConfigConstants.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config
9 - 287 287 1
KinesisProxyInterface.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
11 - 287 287 1
KinesisDeserializationSchema.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization
12 1 287 287 1
KinesisSerializationSchema.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization
12 1 287 287 1
KinesisPartitioner.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
13 2 287 287 1
FullJitterBackoff.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
14 2 287 287 1
RecordPublisher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher
15 - 287 287 1
RecordPublisherFactory.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher
16 1 287 287 1
KinesisConsumerMetricConstants.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics
17 - 287 287 1
FlinkKinesisException.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
17 3 287 287 1
DynamoDBStreamsSchema.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization
18 2 287 287 1
RandomKinesisPartitioner.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
18 3 287 287 1
KinesisProxyV2Interface.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
21 1 287 287 1
TimeoutLatch.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
21 2 287 287 1
DynamoDBStreamsShardHandle.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model
23 3 287 287 1
SentinelSequenceNumber.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model
26 2 287 287 1
PollingRecordPublisherConfiguration.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling
30 4 287 287 1
KinesisDeserializationSchemaWrapper.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization
37 4 287 287 1
RowDataKinesisDeserializationSchema.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table
39 4 287 287 1
Most Recently Created Files (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
KinesisDataFetcher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals
796 44 287 287 1
KinesisConfigUtil.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
347 13 287 287 1
KinesisProxy.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
341 12 287 287 1
FanOutShardSubscriber.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
318 27 183 287 2
FlinkKinesisConsumer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
248 17 287 287 1
FlinkKinesisProducer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
247 16 231 287 2
FanOutRecordPublisherConfiguration.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
221 27 287 287 1
AwsV2Util.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
218 15 183 287 2
StreamConsumerRegistrar.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
176 15 287 287 1
AWSUtil.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
172 9 287 287 1
RecordEmitter.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
169 13 287 287 1
RowDataFieldsKinesisPartitioner.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table
168 9 287 287 1
KinesisOptions.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table
165 8 287 287 1
FanOutRecordPublisher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
160 5 183 287 2
StreamShardMetadata.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model
156 23 287 287 1
KinesisProxyV2.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
145 10 287 287 1
ConsumerConfigConstants.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config
134 2 183 287 2
ShardConsumer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals
134 7 174 287 2
JobManagerWatermarkTracker.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
130 8 287 287 1
PollingRecordPublisher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling
114 6 287 287 1
Most Recently Changed Files (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
StreamConsumerRegistrarUtil.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
101 9 116 287 2
ShardConsumer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals
134 7 174 287 2
ShardConsumerMetricsReporter.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics
49 10 174 287 2
FanOutShardSubscriber.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
318 27 183 287 2
AwsV2Util.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
218 15 183 287 2
FanOutRecordPublisher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
160 5 183 287 2
ConsumerConfigConstants.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config
134 2 183 287 2
KinesisProxyV2Factory.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
30 2 183 287 2
FlinkKinesisProducer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
247 16 231 287 2
KinesisDataFetcher.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals
796 44 287 287 1
KinesisConfigUtil.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
347 13 287 287 1
KinesisProxy.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy
341 12 287 287 1
FlinkKinesisConsumer.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink
248 17 287 287 1
FanOutRecordPublisherConfiguration.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
221 27 287 287 1
StreamConsumerRegistrar.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout
176 15 287 287 1
AWSUtil.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
172 9 287 287 1
RecordEmitter.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util
169 13 287 287 1
RowDataFieldsKinesisPartitioner.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table
168 9 287 287 1
KinesisOptions.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table
165 8 287 287 1
StreamShardMetadata.java
in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model
156 23 287 287 1