Reduce duplicate code among stream processing engines
Besides Kafka Streams, we're working on support for Flink #20 (closed) and Beam #147 (closed), #21 (closed). With more engines, we experience a lot of code duplication.
Hence, for each/some of the benchmarks (UC1-4), commons projects should be introduced, which in particular should provide data classes theodolite.uc3.streamprocessing.HourOfDayKey
.