Shermineh-gh/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
Stargazers
No one’s star this repository yet.