Releases: sodadata/soda-streaming
Releases · sodadata/soda-streaming
POC-3
POC-2.1
v0.0.2-1 inline documentation + restructuring (#1)
POC-2
Phase 2 of the POC includes:
- Implementation of python data-generator
- Integration of Avro serialization in the generator and deserialization in the flink job.
- Implementation of a set of base metrics.
- Implementation of initial Warehouse and Scan file parsers.
- End-to-end demo script, and some small other utility scripts.
- Generic customer naming
POC-1
Phase 1 of the POC:
- docker-compose with kafka cluster + flink cluster
- random data generator that produces strings to kafka
- flink job that produces a message count on a 5-sec tumbling window