path	# lines of code
cfn-templates/flink-refarch-build-artifacts.yml	307
cfn-templates/flink-refarch-infrastructure.yml	437
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/ProcessTaxiStream.java	117
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis/TripEvent.java	24
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis/WatermarkEvent.java	12
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis/Event.java	31
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/EventSchema.java	19
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es/PickupCount.java	10
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es/Document.java	17
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/es/TripDuration.java	14
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/PunctuatedAssigner.java	18
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils/GeoUtils.java	32
flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils/ElasticsearchJestSink.java	102
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/AdaptTimeOption.java	6
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events/TripEvent.java	54
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events/WatermarkEvent.java	14
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/events/Event.java	26
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/BackpressureSemaphore.java	27
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/WatermarkTracker.java	102
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/TaxiEventReader.java	88
kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/StreamPopulator.java	144