Implement a PipelineService and a SensorDataProcessorService