private function createPipelines($bucketParams)
    {
        if (isset($bucketParams['pipelines'])) {
            foreach ($bucketParams['pipelines'] as &$pipelineParams) {
                $pipelineType = $pipelineParams['type'];
                $pipelineParams = $this->pipelineFactory->create($pipelineType, $pipelineParams);
            }
        }

        return $bucketParams;
    }
private function createPipelines($bucketParams)
    {
        if (isset($bucketParams['pipelines'])) {
            foreach ($bucketParams['pipelines'] as &$pipelineParams) {
                $pipelineType = $pipelineParams['type'];
                $pipelineParams = $this->pipelineFactory->create($pipelineType, $pipelineParams);
            }
        }

        return $bucketParams;
    }
private function createPipelines ( $ bucketParams ) { if ( isset ( $ bucketParams [ 'pipelines' ] ) ) { foreach ( $ bucketParams [ 'pipelines' ] as & $ pipelineParams ) { $ pipelineType = $ pipelineParams [ 'type' ] ; $ pipelineParams = $ this -> pipelineFactory -> create ( $ pipelineType , $ pipelineParams ) ; } } return $ bucketParams ; }
Parse bucket params and create PipelineInterface instances

@param array $bucketParams Bucket params.

@return array
Parse bucket params and create PipelineInterface instances