hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipelines/PipelineSelector.java
public void createPipeline(ReplicationType replicationType, String
      pipelineID, List<DatanodeDetails> datanodes) throws IOException {
    PipelineManager manager = getPipelineManager(replicationType);
    Preconditions.checkNotNull(manager, "Found invalid pipeline manager");
    LOG.debug("Creating a pipeline: {} with nodes:{}", pipelineID,
        datanodes.stream().map(DatanodeDetails::toString)
            .collect(Collectors.joining(",")));
    manager.createPipeline(pipelineID, datanodes);
  }
/**
   * Creates a pipeline from a specified set of Nodes.
   */
Creates a pipeline from a specified set of Nodes.
Creates a pipeline from a specified set of Nodes .
public void createPipeline(ReplicationType replicationType, String
      pipelineID, List<DatanodeDetails> datanodes) throws IOException {
    PipelineManager manager = getPipelineManager(replicationType);
    Preconditions.checkNotNull(manager, "Found invalid pipeline manager");
    LOG.debug("Creating a pipeline: {} with nodes:{}", pipelineID,
        datanodes.stream().map(DatanodeDetails::toString)
            .collect(Collectors.joining(",")));
    manager.createPipeline(pipelineID, datanodes);
  }
public void createPipeline ( ReplicationType replicationType , String pipelineID , List < DatanodeDetails > datanodes ) throws IOException { PipelineManager manager = getPipelineManager ( replicationType ) ; Preconditions . checkNotNull ( manager , "Found invalid pipeline manager" ) ; LOG . debug ( "Creating a pipeline: {} with nodes:{}" , pipelineID , datanodes . stream ( ) . map ( DatanodeDetails :: toString ) . collect ( Collectors . joining ( "," ) ) ) ; manager . createPipeline ( pipelineID , datanodes ) ; }
Creates a pipeline from a specified set of Nodes.
Creates a pipeline from a specified set of Nodes .