public function create($pipelineType, $pipelineParams)
    {
        if (!isset($this->factories[$pipelineType])) {
            throw new \LogicException("No factory found for pipeline aggregation of type {$pipelineType}");
        }

        return $this->factories[$pipelineType]->create($pipelineParams);
    }