hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipelines/PipelineSelector.java
public void updateDatanodes(ReplicationType replicationType, String
      pipelineID, List<DatanodeDetails> newDatanodes) throws IOException {
    PipelineManager manager = getPipelineManager(replicationType);
    Preconditions.checkNotNull(manager, "Found invalid pipeline manager");
    LOG.debug("Updating pipeline: {} with new nodes:{}", pipelineID,
        newDatanodes.stream().map(DatanodeDetails::toString)
            .collect(Collectors.joining(",")));
    manager.updatePipeline(pipelineID, newDatanodes);
  }
/**
   * Update the datanodes in the list of the pipeline.
   */
Update the datanodes in the list of the pipeline.
Update the datanodes in the list of the pipeline .
public void updateDatanodes(ReplicationType replicationType, String
      pipelineID, List<DatanodeDetails> newDatanodes) throws IOException {
    PipelineManager manager = getPipelineManager(replicationType);
    Preconditions.checkNotNull(manager, "Found invalid pipeline manager");
    LOG.debug("Updating pipeline: {} with new nodes:{}", pipelineID,
        newDatanodes.stream().map(DatanodeDetails::toString)
            .collect(Collectors.joining(",")));
    manager.updatePipeline(pipelineID, newDatanodes);
  }
public void updateDatanodes ( ReplicationType replicationType , String pipelineID , List < DatanodeDetails > newDatanodes ) throws IOException { PipelineManager manager = getPipelineManager ( replicationType ) ; Preconditions . checkNotNull ( manager , "Found invalid pipeline manager" ) ; LOG . debug ( "Updating pipeline: {} with new nodes:{}" , pipelineID , newDatanodes . stream ( ) . map ( DatanodeDetails :: toString ) . collect ( Collectors . joining ( "," ) ) ) ; manager . updatePipeline ( pipelineID , newDatanodes ) ; }
Update the datanodes in the list of the pipeline.
Update the datanodes in the list of the pipeline .