View Code? Open in Web Editor
NEW
Learn how to develop and test stateful streaming and batch data pipelines
Home Page: http://mkuthan.github.io/tags/#stream-processing
License: Apache License 2.0
Scala 95.35%
Shell 1.33%
HCL 3.32%
stream-processing's Introduction
Learn How To Develop And Test Stateful Streaming Data Pipelines
Shared modules:
stream-processing-shared
- shared utilities for developing stateful streaming data pipelines
stream-processing-infrastructure
- infrastructure layer with IOs for BigQuery, Pubsub and Cloud Storage
stream-processing-test
- shared utilities for testing stateful streaming data pipelines
Use cases:
toll-application
, toll-domain
, toll-infrastructure
- sample application for toll data processing,
see blog post
word-count
- fixed window example,
see blog post
session-window
- session window example,
see blog post