snowplow/beam-enrich

Dataflow job reading tracked events from PubSub, validating and enriching them and writing them back to PubSub

Scala