The distribution of size of files (measured in lines of code).
File | # lines | # units |
---|---|---|
flink-refarch-infrastructure.yml in cfn-templates |
437 | - |
flink-refarch-build-artifacts.yml in cfn-templates |
307 | - |
StreamPopulator.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch |
144 | 4 |
ProcessTaxiStream.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch |
117 | 1 |
ElasticsearchJestSink.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils |
102 | 7 |
WatermarkTracker.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils |
102 | 9 |
TaxiEventReader.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils |
88 | 5 |
TripEvent.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events |
54 | 5 |
GeoUtils.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils |
32 | 5 |
Event.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis |
31 | 1 |
BackpressureSemaphore.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils |
27 | 4 |
Event.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events |
26 | 4 |
TripEvent.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis |
24 | 2 |
EventSchema.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events |
19 | 3 |
PunctuatedAssigner.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events |
18 | 2 |
Document.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es |
17 | 2 |
TripDuration.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es |
14 | 1 |
WatermarkEvent.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events |
14 | 1 |
WatermarkEvent.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis |
12 | 2 |
PickupCount.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es |
10 | 1 |
AdaptTimeOption.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch |
6 | - |
File | # lines | # units |
---|---|---|
WatermarkTracker.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils |
102 | 9 |
ElasticsearchJestSink.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils |
102 | 7 |
GeoUtils.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils |
32 | 5 |
TripEvent.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events |
54 | 5 |
TaxiEventReader.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils |
88 | 5 |
Event.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events |
26 | 4 |
BackpressureSemaphore.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils |
27 | 4 |
StreamPopulator.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch |
144 | 4 |
EventSchema.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events |
19 | 3 |
TripEvent.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis |
24 | 2 |
WatermarkEvent.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis |
12 | 2 |
Document.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es |
17 | 2 |
PunctuatedAssigner.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events |
18 | 2 |
ProcessTaxiStream.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch |
117 | 1 |
Event.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis |
31 | 1 |
PickupCount.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es |
10 | 1 |
TripDuration.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es |
14 | 1 |
WatermarkEvent.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events |
14 | 1 |
There are 9 files with lines longer than 120 characters. In total, there are 37 long lines.
File | # lines | # units | # long lines |
---|---|---|---|
flink-refarch-infrastructure.yml in cfn-templates |
437 | - | 13 |
flink-refarch-build-artifacts.yml in cfn-templates |
307 | - | 12 |
ProcessTaxiStream.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch |
117 | 1 | 3 |
StreamPopulator.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch |
144 | 4 | 3 |
ElasticsearchJestSink.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils |
102 | 7 | 2 |
Event.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis |
31 | 1 | 1 |
TripDuration.java in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es |
14 | 1 | 1 |
TripEvent.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events |
54 | 5 | 1 |
WatermarkTracker.java in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils |
102 | 9 | 1 |