/amazon-managed-service-for-apache-flink-taxi-consumer

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

Primary LanguageJavaApache License 2.0Apache-2.0

Watchers