Skip to content
Snippets Groups Projects

Introduce Abstract Flink Service Class

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

Loading
Loading

Activity

Filter activity
  • Approvals
  • Assignees & reviewers
  • Comments (from bots)
  • Comments (from users)
  • Commits & branches
  • Edits
  • Labels
  • Lock status
  • Mentions
  • Merge request status
  • Tracking
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
  • Loading
Please register or sign in to reply
Loading