aws-samples/amazon-kinesis-analytics-taxi-consumer

Sample Apache Flink application that can be deployed to Kinesis Analytics for Java. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to an Amazon Elasticsearch Service cluster for visualization with Kibana.

JavaApache-2.0

Issues

Elasticsearch update error
#5 opened 3 years ago by frank-tan
1
Reference implementation of unified batch and stream processing on KDA for Java for Flink
#4 opened 5 years ago by thomshib
1
The POM for org.apache.flink:flink-connector-kinesis_2.11:jar:1.8.2 is missing, no dependency information available
#3 opened 5 years ago by arjunsk
3
Map is empty -- the wmsUrl not working
#2 opened 5 years ago by racheliurui
1
Dependency not found: Cannot resolve org.apache.flink:flink-connector-kinesis_2.11:1.6.2
#1 opened 5 years ago by lpiedade
1