Skip to content

Introduce Abstract Flink Service Class

Lorenz Boguhn requested to merge stu203404/theodolite:feature/172-abstract-flink-microservice into master

Closes #172 (closed) Creates an AbstractFlinkService which holds the initialization code and removes a lot of replicated code.

The actual pipelines are still inside of the individual History or AggregationServices implemented in the buildPipeline() methods. The configuration of the serializer needs to be implemented in configureSerializers(). The other methods can be overridden if needed.

Edited by Sören Henning

Merge request reports