hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/client/ContainerOperationClient.java
public void createContainer(String containerId, XceiverClientSpi client,
      Pipeline pipeline) throws IOException {
    String traceID = UUID.randomUUID().toString();
    storageContainerLocationClient.notifyObjectStageChange(
        ObjectStageChangeRequestProto.Type.container,
        containerId,
        ObjectStageChangeRequestProto.Op.create,
        ObjectStageChangeRequestProto.Stage.begin);
    ContainerProtocolCalls.createContainer(client, traceID);
    storageContainerLocationClient.notifyObjectStageChange(
        ObjectStageChangeRequestProto.Type.container,
        containerId,
        ObjectStageChangeRequestProto.Op.create,
        ObjectStageChangeRequestProto.Stage.complete);

    // Let us log this info after we let SCM know that we have completed the
    // creation state.
    if (LOG.isDebugEnabled()) {
      LOG.debug("Created container " + containerId
          + " leader:" + pipeline.getLeader()
          + " machines:" + pipeline.getMachines());
    }
  }
/**
   * Create a container over pipeline specified by the SCM.
   *
   * @param containerId - Container ID
   * @param client - Client to communicate with Datanodes
   * @param pipeline - A pipeline that is already created.
   * @throws IOException
   */
Create a container over pipeline specified by the SCM.
@param containerId - Container ID
@param client - Client to communicate with Datanodes
@param pipeline - A pipeline that is already created.
Create a container over pipeline specified by the SCM . @param containerId - Container ID @param client - Client to communicate with Datanodes @param pipeline - A pipeline that is already created .
public void createContainer(String containerId, XceiverClientSpi client,
      Pipeline pipeline) throws IOException {
    String traceID = UUID.randomUUID().toString();
    storageContainerLocationClient.notifyObjectStageChange(
        ObjectStageChangeRequestProto.Type.container,
        containerId,
        ObjectStageChangeRequestProto.Op.create,
        ObjectStageChangeRequestProto.Stage.begin);
    ContainerProtocolCalls.createContainer(client, traceID);
    storageContainerLocationClient.notifyObjectStageChange(
        ObjectStageChangeRequestProto.Type.container,
        containerId,
        ObjectStageChangeRequestProto.Op.create,
        ObjectStageChangeRequestProto.Stage.complete);
    if (LOG.isDebugEnabled()) {
      LOG.debug("Created container " + containerId
          + " leader:" + pipeline.getLeader()
          + " machines:" + pipeline.getMachines());
    }
  }
public void createContainer ( String containerId , XceiverClientSpi client , Pipeline pipeline ) throws IOException { String traceID = UUID . randomUUID ( ) . toString ( ) ; storageContainerLocationClient . notifyObjectStageChange ( ObjectStageChangeRequestProto . Type . container , containerId , ObjectStageChangeRequestProto . Op . create , ObjectStageChangeRequestProto . Stage . begin ) ; ContainerProtocolCalls . createContainer ( client , traceID ) ; storageContainerLocationClient . notifyObjectStageChange ( ObjectStageChangeRequestProto . Type . container , containerId , ObjectStageChangeRequestProto . Op . create , ObjectStageChangeRequestProto . Stage . complete ) ; if ( LOG . isDebugEnabled ( ) ) { LOG . debug ( "Created container " + containerId + " leader:" + pipeline . getLeader ( ) + " machines:" + pipeline . getMachines ( ) ) ; } }
Create a container over pipeline specified by the SCM.
Create a container over pipeline specified by the SCM .
// Let us log this info after we let SCM know that we have completed the // creation state.