How alpinegizmo/flink-mobile-data-usage works
This repository is a Flink mobile-data-usage example: an operator runs a producer to populate Kafka’s input topic, then can run separate Flink jobs that consume it for quota enrichment, batch or streaming totals, and alerting. The README documents those inputs and job purposes, but no source excerpts are available, so internal calls, generated outputs, and downstream destinations are not inferred.
Main entry points: KafkaProducerJob.java Kafka Producer Job · QuotaEnrichmentJob.java Quota Enrichment Job · TotalUsageBatchJob.java Batch Totals Job · TotalUsageStreamingJob.java Streaming Totals Job
Components 8
Data Ingestion
- Kafka Producer Job
src/main/java/com/ververica/flink/example/datausage/KafkaProducerJob.java - Kafka Input Topic
Quota Enrichment
- Quota Enrichment Job
src/main/java/com/ververica/flink/example/datausage/QuotaEnrichmentJob.java
Usage Analytics
- Batch Totals Job
src/main/java/com/ververica/flink/example/datausage/TotalUsageBatchJob.java - Streaming Totals Job
src/main/java/com/ververica/flink/example/datausage/TotalUsageStreamingJob.java
Usage Alerting
- Process Alerting Job
src/main/java/com/ververica/flink/example/datausage/UsageAlertingProcessFunctionJob.java - SQL Alerting Job
src/main/java/com/ververica/flink/example/datausage/UsageAlertingSQLJob.java
Other components
- Operator
Connections 12
- Operator → Kafka Producer Job: runs first
- Kafka Producer Job → Kafka Input Topic: populates input
- Operator → Quota Enrichment Job: runs
- Operator → Batch Totals Job: runs
- Operator → Streaming Totals Job: runs
- Operator → Process Alerting Job: runs
- Operator → SQL Alerting Job: runs
- Kafka Input Topic → Quota Enrichment Job: read by
- Kafka Input Topic → Batch Totals Job: read by
- Kafka Input Topic → Streaming Totals Job: read by
- Kafka Input Topic → Process Alerting Job: read by
- Kafka Input Topic → SQL Alerting Job: read by