Skip to content

GitLab

Explore

Sign in

Primary navigation

Project

openaq
- Activity
- Members
- Labels
- Issues
- Issue boards
- Milestones
- Wiki
- Releases
- Model registry
- Environments
- Incidents

Snippets Groups Projects

56614f4e

Commit 56614f4e authored 6 years ago by ashagp2

Downloads
- Patches
- Plain Diff

Spark+Kafka integration. Calculated AQI written to Hbase

parent 21be0694

No related branches found

No related tags found

No related merge requests found

Changes 5

Hide whitespace changes

Inline Side-by-side

Showing

AQICalculationModule/pom.xml 64 additions, 1 deletion

AQICalculationModule/pom.xml
AQICalculationModule/src/main/java/CalculateAQIMain.java 157 additions, 12 deletions

AQICalculationModule/src/main/java/CalculateAQIMain.java
AQICalculationModule/src/main/java/CalculateAQIMainKafka.java 393 additions, 0 deletions

...alculationModule/src/main/java/CalculateAQIMainKafka.java
AQICalculationModule/src/main/java/PrepareHBase.java 121 additions, 0 deletions

AQICalculationModule/src/main/java/PrepareHBase.java
AQICalculationModule/src/main/resources/breakpoints.csv 8 additions, 0 deletions

AQICalculationModule/src/main/resources/breakpoints.csv

with 743 additions and 13 deletions

Loading

0% Loading or .

You are about to add 0 people to the discussion. Proceed with caution.

Finish editing this message first!

Please register or sign in to comment