Path	Lines of Code
CODE_OF_CONDUCT.md	4
CONTRIBUTING.md	38
README.md	21
misc/pickup-count-index.json	15
misc/trip-duration-index.json	20
pom.xml	154
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/ProcessTaxiStream.java	91
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/ProcessTaxiStreamLocal.java	50
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/EventDeserializationSchema.java	33
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/TimestampAssigner.java	18
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/es/AverageTripDuration.java	14
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/es/Document.java	17
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/es/PickupCount.java	10
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/flink/TripDuration.java	16
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/flink/TripGeoHash.java	10
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/kinesis/Event.java	34
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/kinesis/TripEvent.java	42
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/events/kinesis/WatermarkEvent.java	21
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/operators/AmazonElasticsearchSink.java	79
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/operators/CountByGeoHash.java	16
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/operators/TripDurationToAverageTripDuration.java	25
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/operators/TripToGeoHash.java	11
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/operators/TripToTripDuration.java	20
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/utils/GeoUtils.java	36
src/main/java/com/amazonaws/samples/kaja/taxi/consumer/utils/ParameterToolUtils.java	12
src/main/resources/log4j.properties	20
src/main/resources/testProperties.json	11
workshop/README.md	4