path # lines of code number of updates days since first update days since last update first updated last updated cfn-templates/flink-refarch-build-artifacts.yml 307 8 1643 706 2017-08-03 2020-02-26 cfn-templates/flink-refarch-infrastructure.yml 437 13 1643 711 2017-08-03 2020-02-21 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/ProcessTaxiStream.java 117 6 1643 1252 2017-08-03 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis/TripEvent.java 24 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis/WatermarkEvent.java 12 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis/Event.java 31 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/EventSchema.java 19 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es/PickupCount.java 10 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es/Document.java 17 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es/TripDuration.java 14 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/PunctuatedAssigner.java 18 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils/GeoUtils.java 32 2 1614 1252 2017-09-01 2018-08-29 flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils/ElasticsearchJestSink.java 102 3 1614 1252 2017-09-01 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/AdaptTimeOption.java 6 2 1358 1252 2018-05-15 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events/TripEvent.java 54 6 1625 1252 2017-08-21 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events/WatermarkEvent.java 14 3 1625 1252 2017-08-21 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events/Event.java 26 4 1625 1252 2017-08-21 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/BackpressureSemaphore.java 27 3 1617 1252 2017-08-29 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/WatermarkTracker.java 102 8 1638 1252 2017-08-08 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/TaxiEventReader.java 88 7 1638 1252 2017-08-08 2018-08-29 kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/StreamPopulator.java 144 11 1643 1252 2017-08-03 2018-08-29