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

Name		Name	Last commit message	Last commit date
Latest commit History 374 Commits
.github		.github
project		project
stream-processing-infrastructure/src		stream-processing-infrastructure/src
stream-processing-shared/src		stream-processing-shared/src
stream-processing-test/src		stream-processing-test/src
toll-application		toll-application
toll-domain/src		toll-domain/src
toll-infrastructure		toll-infrastructure
user-sessions/src		user-sessions/src
word-count/src		word-count/src
.git-blame-ignore-revs		.git-blame-ignore-revs
.gitignore		.gitignore
.scala-steward.conf		.scala-steward.conf
.scalafix.conf		.scalafix.conf
.scalafmt.conf		.scalafmt.conf
LICENSE		LICENSE
README.md		README.md
build.sbt		build.sbt

mkuthan/stream-processing