aws-samples / amazon-kinesis-data-analytics-java-examples
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: 39
  • Daily file updates (only one update per file and date counted): 115
  • First update: 2019-04-22
  • Latest update: 2022-01-21
  • Days between first and latest update: 1006 (143 weeks, estimated 715 working days)
  • Active days (at least one file change): 38
  • Data:
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 39 files with 2,156 lines of code in files.
    • 22 files that are 366+ days old (1,179 lines of code)
    • 4 files that are 181-365 days old (319 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 8 files that are 31-90 days old (405 lines of code)
    • 5 files that are 1-30 days old (253 lines of code)
54% | 14% | 0% | 18% | 11%
Legend:
366+
181-365
91-180
31-90
1-30
Latest Change Distribution Overall
Days since last update
  • There are 39 files with 2,156 lines of code in files.
    • 18 files have been last changed 366+ days ago (971 lines of code)
    • 0 files have been last changed 181-365 days ago (0 lines of code)
    • 1 files have been last changed 91-180 days ago (46 lines of code)
    • 15 files have been last changed 31-90 days ago (886 lines of code)
    • 5 files have been last changed 1-30 days ago (253 lines of code)
45% | 0% | 2% | 41% | 11%
Legend:
366+
181-365
91-180
31-90
1-30
File Change History per File Extension
java, xml, json, py, md, txt, gitignore, properties
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java63% | 0% | 0% | 22% | 14%
py8% | 91% | 0% | 0% | 0%
Latest Change Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java52% | 0% | 2% | 31% | 14%
py8% | 0% | 0% | 91% | 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
GettingStartedTable100% | 0% | 0% | 0% | 0%
CustomMetrics100% | 0% | 0% | 0% | 0%
Beam100% | 0% | 0% | 0% | 0%
CloudWatchSink100% | 0% | 0% | 0% | 0%
CustomKeystore100% | 0% | 0% | 0% | 0%
TumblingWindow100% | 0% | 0% | 0% | 0%
SlidingWindow100% | 0% | 0% | 0% | 0%
S3Sink100% | 0% | 0% | 0% | 0%
GettingStarted_1_8100% | 0% | 0% | 0% | 0%
GettingStarted_1_6100% | 0% | 0% | 0% | 0%
GettingStarted100% | 0% | 0% | 0% | 0%
FirehoseSink100% | 0% | 0% | 0% | 0%
EfoConsumer100% | 0% | 0% | 0% | 0%
KafkaConnectors100% | 0% | 0% | 0% | 0%
python0% | 100% | 0% | 0% | 0%
LambdaSink0% | 0% | 0% | 100% | 0%
S3ParquetSink0% | 0% | 0% | 100% | 0%
SQSSink0% | 0% | 0% | 100% | 0%
GettingStarted_1_110% | 0% | 0% | 100% | 0%
KeyspacesSink0% | 0% | 0% | 0% | 100%
HudiConnector0% | 0% | 0% | 0% | 100%
primary (latest change distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
GettingStartedTable100% | 0% | 0% | 0% | 0%
CustomMetrics100% | 0% | 0% | 0% | 0%
Beam100% | 0% | 0% | 0% | 0%
CloudWatchSink100% | 0% | 0% | 0% | 0%
CustomKeystore100% | 0% | 0% | 0% | 0%
GettingStarted_1_8100% | 0% | 0% | 0% | 0%
GettingStarted_1_6100% | 0% | 0% | 0% | 0%
GettingStarted100% | 0% | 0% | 0% | 0%
FirehoseSink100% | 0% | 0% | 0% | 0%
KafkaConnectors100% | 0% | 0% | 0% | 0%
EfoConsumer0% | 0% | 100% | 0% | 0%
python0% | 0% | 0% | 100% | 0%
LambdaSink0% | 0% | 0% | 100% | 0%
S3ParquetSink0% | 0% | 0% | 100% | 0%
SQSSink0% | 0% | 0% | 100% | 0%
TumblingWindow0% | 0% | 0% | 100% | 0%
SlidingWindow0% | 0% | 0% | 100% | 0%
S3Sink0% | 0% | 0% | 100% | 0%
GettingStarted_1_110% | 0% | 0% | 100% | 0%
KeyspacesSink0% | 0% | 0% | 0% | 100%
HudiConnector0% | 0% | 0% | 0% | 100%
Oldest Files (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
CustomSinkStreamingJob.java
in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics
84 3 1008 1008 1
TumblingWindowStreamingJob.java
in TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics
55 3 85 1008 2
SlidingWindowStreamingJobWithParallelism.java
in SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics
54 3 85 1008 2
CloudWatchLogSink.java
in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/sink
54 4 1008 1008 1
BasicStreamingJob.java
in GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 1008 1008 1
FirehoseSinkStreamingJob.java
in FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics
50 3 1008 1008 1
KafkaGettingStartedJob.java
in KafkaConnectors/src/main/java/com/amazonaws/services/kinesisanalytics
36 3 705 799 3
S3StreamingSinkJob.java
in S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics
53 3 85 777 3
BasicStreamingJob.java
in GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 777 777 1
RecordCountApplication.java
in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics
75 4 630 630 1
WordCountApplication.java
in CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics
61 5 630 630 1
RecordSchemaHelper.java
in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics
25 3 368 630 2
CustomFlinkKafkaConsumer.java
in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics
45 3 595 595 1
KDAFlinkStreamingJob.java
in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics
41 3 595 595 1
BasicBeamStreamingJob.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
75 4 505 509 2
DefaultCredentialsProviderClientsProvider.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
29 4 505 509 2
BasicBeamStreamingJobOptions.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
12 - 505 509 2
BasicBeamStreamingJobOptionsParser.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
36 - 505 505 1
EfoApplication.java
in EfoConsumer/src/main/java/software/amazon/kinesis
46 3 111 482 2
StreamingJob.java
in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics
168 7 439 439 1
Files Not Recently Changed (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
FirehoseSinkStreamingJob.java
in FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics
50 3 1008 1008 1
BasicStreamingJob.java
in GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 1008 1008 1
CloudWatchLogSink.java
in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/sink
54 4 1008 1008 1
CustomSinkStreamingJob.java
in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics
84 3 1008 1008 1
BasicStreamingJob.java
in GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 777 777 1
KafkaGettingStartedJob.java
in KafkaConnectors/src/main/java/com/amazonaws/services/kinesisanalytics
36 3 705 799 3
WordCountApplication.java
in CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics
61 5 630 630 1
RecordCountApplication.java
in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics
75 4 630 630 1
KDAFlinkStreamingJob.java
in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics
41 3 595 595 1
CustomFlinkKafkaConsumer.java
in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics
45 3 595 595 1
BasicBeamStreamingJobOptions.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
12 - 505 509 2
DefaultCredentialsProviderClientsProvider.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
29 4 505 509 2
BasicBeamStreamingJobOptionsParser.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
36 - 505 505 1
BasicBeamStreamingJob.java
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam
75 4 505 509 2
stock.py
in GettingStartedTable/src/main/python
30 1 439 439 1
StreamingJob.java
in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics
168 7 439 439 1
BasicStreamingJob.java
in GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 406 406 1
RecordSchemaHelper.java
in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics
25 3 368 630 2
EfoApplication.java
in EfoConsumer/src/main/java/software/amazon/kinesis
46 3 111 482 2
BasicStreamingJob.java
in GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 85 85 1
Most Recently Created Files (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
TurbineSensorMessageModel.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
9 - 11 12 2
TurbineSpeedAggregator.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
97 5 11 14 3
TurbineAggregatedRecord.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
60 13 11 14 2
QueryOptionsSerializable.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
6 - 11 14 2
StreamingJob.java
in HudiConnector/src/main/java/basic/application
81 2 20 27 3
LambdaSinkJob.java
in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics
45 3 70 70 1
AwsLambdaSink.java
in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics
139 11 70 71 2
S3StreamingParquetSinkJob.java
in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics
62 3 70 71 2
SQSSinkJob.java
in SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics
47 3 70 71 2
TickCount.java
in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics
21 5 70 71 2
TickCount.java
in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics
21 5 70 71 2
StandardSqsSink.java
in SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics
20 2 70 71 2
BasicStreamingJob.java
in GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 85 85 1
streaming-file-sink.py
in python/S3Sink
91 6 69 313 4
sliding-windows.py
in python/SlidingWindow
79 5 69 313 4
tumbling-windows.py
in python/TumblingWindow
76 5 69 313 4
getting-started.py
in python/GettingStarted
73 5 69 313 3
BasicStreamingJob.java
in GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 406 406 1
StreamingJob.java
in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics
168 7 439 439 1
stock.py
in GettingStartedTable/src/main/python
30 1 439 439 1
Most Recently Changed Files (Top 20)
File# lines# unitslast modified
(days ago)
created
(days ago)
# changes
TurbineSpeedAggregator.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
97 5 11 14 3
TurbineAggregatedRecord.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
60 13 11 14 2
TurbineSensorMessageModel.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
9 - 11 12 2
QueryOptionsSerializable.java
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics
6 - 11 14 2
StreamingJob.java
in HudiConnector/src/main/java/basic/application
81 2 20 27 3
streaming-file-sink.py
in python/S3Sink
91 6 69 313 4
sliding-windows.py
in python/SlidingWindow
79 5 69 313 4
tumbling-windows.py
in python/TumblingWindow
76 5 69 313 4
getting-started.py
in python/GettingStarted
73 5 69 313 3
AwsLambdaSink.java
in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics
139 11 70 71 2
S3StreamingParquetSinkJob.java
in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics
62 3 70 71 2
SQSSinkJob.java
in SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics
47 3 70 71 2
LambdaSinkJob.java
in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics
45 3 70 70 1
TickCount.java
in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics
21 5 70 71 2
TickCount.java
in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics
21 5 70 71 2
StandardSqsSink.java
in SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics
20 2 70 71 2
TumblingWindowStreamingJob.java
in TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics
55 3 85 1008 2
SlidingWindowStreamingJobWithParallelism.java
in SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics
54 3 85 1008 2
S3StreamingSinkJob.java
in S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics
53 3 85 777 3
BasicStreamingJob.java
in GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics
50 5 85 85 1