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).
File | # lines | # units | last 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 |
File | # lines | # units | last 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 |
File | # lines | # units | last 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 |
File | # lines | # units | last 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 |