Method CreateDir

cpp/src/arrow/filesystem/azurefs.cc:3351–3392

}

Status AzureFileSystem::CreateDir(const std::string& path, bool recursive) {
  ARROW_ASSIGN_OR_RAISE(auto location, AzureLocation::FromString(path));
  if (location.container.empty()) {
    return Status::Invalid("CreateDir requires a non-empty path.");
  }

  auto container_client = impl_->GetBlobContainerClient(location.container);
  if (location.path.empty()) {
    // If the path is just the container, the parent (root) trivially exists,
    // and the CreateDir operation comes down to just creating the container.
    return CreateContainerIfNotExists(location.container, container_client);
  }

  auto adlfs_client = impl_->GetFileSystemClient(location.container);
  ARROW_ASSIGN_OR_RAISE(auto hns_support,
                        impl_->HierarchicalNamespaceSupport(adlfs_client));
  if (hns_support == HNSSupport::kContainerNotFound) {
    if (!recursive) {
      auto parent = location.parent();
      return PathNotFound(parent);
    }
    RETURN_NOT_OK(CreateContainerIfNotExists(location.container, container_client));
    // Perform a second check for HNS support after creating the container.
    ARROW_ASSIGN_OR_RAISE(hns_support, impl_->HierarchicalNamespaceSupport(adlfs_client));
    if (hns_support == HNSSupport::kContainerNotFound) {
      // We only get kContainerNotFound if we are unable to read the properties of the
      // container we just created. This is very unlikely, but theoretically possible in
      // a concurrent system, so the error is handled to avoid infinite recursion.
      return Status::IOError("Unable to read properties of a newly created container: ",
                             location.container, ": " + container_client.GetUrl());
    }
  }
  // CreateDirOnFileSystem and CreateDirOnContainer can handle the container
  // not existing which is useful and necessary here since the only reason
  // a container was created above was to check for HNS support when it wasn't
  // cached yet.
  if (hns_support == HNSSupport::kEnabled) {
    return impl_->CreateDirOnFileSystem(adlfs_client, location, recursive);
  }
  DCHECK_EQ(hns_support, HNSSupport::kDisabled);
  return impl_->CreateDirOnContainer(container_client, location, recursive);
}

Status AzureFileSystem::DeleteDir(const std::string& path) {
  ARROW_ASSIGN_OR_RAISE(auto location, AzureLocation::FromString(path));