hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipelines/PipelineSelector.java
public void closePipeline(ReplicationType replicationType, String
      pipelineID) throws IOException {
    PipelineManager manager = getPipelineManager(replicationType);
    Preconditions.checkNotNull(manager, "Found invalid pipeline manager");
    LOG.debug("Closing pipeline. pipelineID: {}", pipelineID);
    manager.closePipeline(pipelineID);
  }
/**
   * Close the  pipeline with the given clusterId.
   */
Close the  pipeline with the given clusterId.
Close the pipeline with the given clusterId .
public void closePipeline(ReplicationType replicationType, String
      pipelineID) throws IOException {
    PipelineManager manager = getPipelineManager(replicationType);
    Preconditions.checkNotNull(manager, "Found invalid pipeline manager");
    LOG.debug("Closing pipeline. pipelineID: {}", pipelineID);
    manager.closePipeline(pipelineID);
  }
public void closePipeline ( ReplicationType replicationType , String pipelineID ) throws IOException { PipelineManager manager = getPipelineManager ( replicationType ) ; Preconditions . checkNotNull ( manager , "Found invalid pipeline manager" ) ; LOG . debug ( "Closing pipeline. pipelineID: {}" , pipelineID ) ; manager . closePipeline ( pipelineID ) ; }
Close the  pipeline with the given clusterId.
Close the pipeline with the given clusterId .