DataLakeDirectoryAsyncClient Classe
- java.
lang. Object - com.
azure. storage. file. datalake. DataLakePathAsyncClient - com.
azure. storage. file. datalake. DataLakeDirectoryAsyncClient
- com.
- com.
public final class DataLakeDirectoryAsyncClient
extends DataLakePathAsyncClient
Cette classe fournit un client qui contient des opérations d’annuaire pour Azure Storage Data Lake. Les opérations fournies par ce client incluent la création d’un répertoire, la suppression d’un répertoire, le renommage d’un répertoire, la définition des métadonnées et des en-têtes http, la définition et la récupération du contrôle d’accès, l’obtention de propriétés et la création et la suppression de fichiers et de sous-répertoires.
Ce client est instancié via DataLakePathClientBuilder ou récupéré via getDirectoryAsyncClient(String directoryName).
Pour plus d’informations, consultez Azure Docs .
Résumé de la méthode
Méthodes héritées de DataLakePathAsyncClient
Méthodes héritées de java.lang.Object
Détails de la méthode
createFile
public Mono
Crée un fichier dans un répertoire. Par défaut, cette méthode ne remplace pas un fichier existant. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeFileAsyncClient fileClient = client.createFile(fileName).block();
Parameters:
Returns:
createFile
public Mono
Crée un fichier dans un répertoire. Pour plus d’informations, consultez Azure Docs.
Exemples de code
boolean overwrite = false; /* Default value. */
DataLakeFileAsyncClient fClient = client.createFile(fileName, overwrite).block();
Parameters:
Returns:
createFileIfNotExists
public Mono
Crée un fichier dans un répertoire s’il n’existe pas. Par défaut, cette méthode ne remplace pas un fichier existant. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeFileAsyncClient fileClient = client.createFileIfNotExists(fileName).block();
Parameters:
Returns:
createFileIfNotExistsWithResponse
public Mono
Crée un fichier dans un répertoire s’il n’existe pas. Pour plus d’informations, consultez Azure Docs.
Exemples de code
PathHttpHeaders headers = new PathHttpHeaders()
.setContentLanguage("en-US")
.setContentType("binary");
String permissions = "permissions";
String umask = "umask";
DataLakePathCreateOptions options = new DataLakePathCreateOptions()
.setPermissions(permissions)
.setUmask(umask)
.setPathHttpHeaders(headers)
.setMetadata(Collections.singletonMap("metadata", "value"));
client.createFileIfNotExistsWithResponse(fileName, options).subscribe(response -> {
if (response.getStatusCode() == 409) {
System.out.println("Already exists.");
} else {
System.out.println("successfully created.");
}
});
Parameters:
Returns:
createFileWithResponse
public Mono
Crée un fichier dans un répertoire. Si un fichier portant le même nom existe déjà, le fichier est remplacé. Pour plus d’informations, consultez Azure Docs.
Exemples de code
PathHttpHeaders httpHeaders = new PathHttpHeaders()
.setContentLanguage("en-US")
.setContentType("binary");
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
Map<String, String> metadata = Collections.singletonMap("metadata", "value");
String permissions = "permissions";
String umask = "umask";
String owner = "rwx";
String group = "r--";
String leaseId = CoreUtils.randomUuid().toString();
Integer duration = 15;
DataLakePathCreateOptions options = new DataLakePathCreateOptions()
.setPermissions(permissions)
.setUmask(umask)
.setOwner(owner)
.setGroup(group)
.setPathHttpHeaders(httpHeaders)
.setRequestConditions(requestConditions)
.setMetadata(metadata)
.setProposedLeaseId(leaseId)
.setLeaseDuration(duration);
DataLakeFileAsyncClient newFileClient = client.createFileWithResponse(fileName, options).block().getValue();
Parameters:
Returns:
createFileWithResponse
public Mono
Crée un fichier dans un répertoire. Si un fichier portant le même nom existe déjà, le fichier est remplacé. Pour plus d’informations, consultez Azure Docs.
Exemples de code
PathHttpHeaders httpHeaders = new PathHttpHeaders()
.setContentLanguage("en-US")
.setContentType("binary");
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
String permissions = "permissions";
String umask = "umask";
DataLakeFileAsyncClient newFileClient = client.createFileWithResponse(fileName,
permissions, umask, httpHeaders, Collections.singletonMap("metadata", "value"), requestConditions
).block().getValue();
Parameters:
Returns:
createSubdirectory
public Mono
Crée un sous-répertoire dans un répertoire. Par défaut, cette méthode ne remplace pas un sous-répertoire existant. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeDirectoryAsyncClient directoryClient = client.createSubdirectory(directoryName).block();
Parameters:
Returns:
createSubdirectory
public Mono
Crée un sous-répertoire dans un répertoire. Pour plus d’informations, consultez Azure Docs.
Exemples de code
boolean overwrite = false; /* Default value. */
DataLakeDirectoryAsyncClient dClient = client.createSubdirectory(directoryName, overwrite).block();
Parameters:
Returns:
createSubdirectoryIfNotExists
public Mono
Crée un sous-répertoire dans un répertoire s’il n’existe pas. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeDirectoryAsyncClient subdirectoryClient = client.createSubdirectoryIfNotExists(directoryName).block();
Parameters:
Returns:
createSubdirectoryIfNotExistsWithResponse
public Mono
Crée un sous-répertoire dans un répertoire s’il n’existe pas. Pour plus d’informations, consultez Azure Docs.
Exemples de code
PathHttpHeaders headers = new PathHttpHeaders()
.setContentLanguage("en-US")
.setContentType("binary");
String permissions = "permissions";
String umask = "umask";
DataLakePathCreateOptions options = new DataLakePathCreateOptions()
.setPermissions(permissions)
.setUmask(umask)
.setPathHttpHeaders(headers)
.setMetadata(Collections.singletonMap("metadata", "value"));
client.createSubdirectoryIfNotExistsWithResponse(directoryName, options).subscribe(response -> {
if (response.getStatusCode() == 409) {
System.out.println("Already exists.");
} else {
System.out.println("successfully created.");
}
});
Parameters:
Returns:
createSubdirectoryWithResponse
public Mono
Crée un sous-répertoire dans un répertoire. Si un sous-répertoire portant le même nom existe déjà, le sous-répertoire est remplacé. Pour plus d’informations, consultez Azure Docs.
Exemples de code
PathHttpHeaders httpHeaders = new PathHttpHeaders()
.setContentLanguage("en-US")
.setContentType("binary");
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
Map<String, String> metadata = Collections.singletonMap("metadata", "value");
String permissions = "permissions";
String umask = "umask";
String owner = "rwx";
String group = "r--";
String leaseId = CoreUtils.randomUuid().toString();
Integer duration = 15;
DataLakePathCreateOptions options = new DataLakePathCreateOptions()
.setPermissions(permissions)
.setUmask(umask)
.setOwner(owner)
.setGroup(group)
.setPathHttpHeaders(httpHeaders)
.setRequestConditions(requestConditions)
.setMetadata(metadata)
.setProposedLeaseId(leaseId)
.setLeaseDuration(duration);
DataLakeDirectoryAsyncClient newDirectoryClient = client.createSubdirectoryWithResponse(directoryName, options)
.block().getValue();
Parameters:
Returns:
createSubdirectoryWithResponse
public Mono
Crée un sous-répertoire dans un répertoire. Si un sous-répertoire portant le même nom existe déjà, le sous-répertoire est remplacé. Pour plus d’informations, consultez Azure Docs.
Exemples de code
PathHttpHeaders httpHeaders = new PathHttpHeaders()
.setContentLanguage("en-US")
.setContentType("binary");
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
String permissions = "permissions";
String umask = "umask";
DataLakeDirectoryAsyncClient newDirectoryClient = client.createSubdirectoryWithResponse(
directoryName, permissions, umask, httpHeaders, Collections.singletonMap("metadata", "value"),
requestConditions
).block().getValue();
Parameters:
Returns:
delete
public Mono
Supprime un répertoire.
Exemples de code
client.delete().subscribe(response ->
System.out.println("Delete request completed"));
Pour plus d’informations, consultez Azure Docs.
Returns:
deleteFile
public Mono
Supprime le fichier spécifié dans le système de fichiers. Si le fichier n’existe pas, l’opération échoue. Pour plus d’informations, consultez Azure Docs.
Exemples de code
client.deleteFile(fileName).subscribe(response ->
System.out.println("Delete request completed"));
Parameters:
Returns:
deleteFileIfExists
public Mono
Supprime le fichier spécifié dans le système de fichiers s’il existe. Pour plus d’informations, consultez Azure Docs.
Exemples de code
client.deleteFileIfExists(fileName).subscribe(deleted -> {
if (deleted) {
System.out.println("successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Parameters:
Returns:
true indique que le fichier spécifié a été supprimé avec succès, false indique que le fichier spécifié n’existait pas.deleteFileIfExistsWithResponse
public Mono
Supprime le fichier spécifié dans le répertoire s’il existe. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
DataLakePathDeleteOptions options = new DataLakePathDeleteOptions().setIsRecursive(false)
.setRequestConditions(requestConditions);
client.deleteFileIfExistsWithResponse(fileName, options).subscribe(response -> {
if (response.getStatusCode() == 404) {
System.out.println("Does not exist.");
} else {
System.out.println("successfully deleted.");
}
});
Parameters:
Returns:
deleteFileWithResponse
public Mono
Supprime le fichier spécifié dans le répertoire. Si le fichier n’existe pas, l’opération échoue. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
client.deleteFileWithResponse(fileName, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Parameters:
Returns:
deleteIfExists
public Mono
Supprime un répertoire s’il existe.
Exemples de code
client.deleteIfExists().subscribe(deleted -> {
if (deleted) {
System.out.println("Successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Pour plus d’informations, consultez Azure Docs
Overrides:
DataLakeDirectoryAsyncClient.deleteIfExists()Returns:
true indique que le répertoire a été supprimé avec succès, true indique que le répertoire n’existait pas.deleteIfExistsWithResponse
public Mono
Supprime un répertoire s’il existe.
Exemples de code
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
DataLakePathDeleteOptions options = new DataLakePathDeleteOptions().setIsRecursive(recursive)
.setRequestConditions(requestConditions);
client.deleteIfExistsWithResponse(options).subscribe(response -> {
if (response.getStatusCode() == 404) {
System.out.println("Does not exist.");
} else {
System.out.println("successfully deleted.");
}
});
Pour plus d’informations, consultez Azure Docs
Overrides:
DataLakeDirectoryAsyncClient.deleteIfExistsWithResponse(DataLakePathDeleteOptions options)Parameters:
Returns:
deleteRecursively
public Mono
Supprime de manière récursive un répertoire et tout le contenu du répertoire.
Exemples de code
client.deleteRecursively().subscribe(response ->
System.out.println("Delete request completed"));
Pour plus d’informations, consultez Azure Docs
Returns:
deleteRecursivelyWithResponse
public Mono
Supprime de manière récursive un répertoire et tout le contenu du répertoire.
Exemples de code
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
client.deleteWithResponse(recursive, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Pour plus d’informations, consultez Azure Docs
Parameters:
Returns:
deleteSubdirectory
public Mono
Supprime le sous-répertoire spécifié dans le répertoire. Si le sous-répertoire n’existe pas ou n’est pas vide, l’opération échoue. Pour plus d’informations, consultez Azure Docs.
Exemples de code
client.deleteSubdirectory(directoryName).subscribe(response ->
System.out.println("Delete request completed"));
Parameters:
Returns:
deleteSubdirectoryIfExists
public Mono
Supprime le sous-répertoire spécifié dans le répertoire s’il existe. Pour plus d’informations, consultez Azure Docs.
Exemples de code
client.deleteSubdirectoryIfExists(directoryName).subscribe(deleted -> {
if (deleted) {
System.out.println("Successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Parameters:
Returns:
true indique que le sous-répertoire a été supprimé.
false indique que le sous-répertoire spécifié n’existe pas.deleteSubdirectoryIfExistsWithResponse
public Mono
Supprime le sous-répertoire spécifié dans le répertoire s’il existe. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
DataLakePathDeleteOptions options = new DataLakePathDeleteOptions().setIsRecursive(recursive)
.setRequestConditions(requestConditions);
client.deleteSubdirectoryIfExistsWithResponse(directoryName, options).subscribe(response -> {
if (response.getStatusCode() == 404) {
System.out.println("Does not exist.");
} else {
System.out.println("successfully deleted.");
}
});
Parameters:
Returns:
deleteSubdirectoryWithResponse
public Mono
Supprime le sous-répertoire spécifié dans le répertoire. Si le sous-répertoire n’existe pas ou n’est pas vide, l’opération échoue. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
client.deleteSubdirectoryWithResponse(directoryName, recursive, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Parameters:
Returns:
deleteWithResponse
public Mono
Supprime un répertoire.
Exemples de code
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
client.deleteWithResponse(recursive, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Pour plus d’informations, consultez Azure Docs
Parameters:
Returns:
getCustomerProvidedKeyAsyncClient
public DataLakeDirectoryAsyncClient getCustomerProvidedKeyAsyncClient(CustomerProvidedKey customerProvidedKey)
Crée un nouveau DataLakeDirectoryAsyncClient avec le customerProvidedKey spécifié.
Overrides:
DataLakeDirectoryAsyncClient.getCustomerProvidedKeyAsyncClient(CustomerProvidedKey customerProvidedKey)Parameters:
null à n’utiliser aucune clé fournie par le CustomerProvidedKey client.
Returns:
customerProvidedKey.getDirectoryName
public String getDirectoryName()
Obtient le nom de ce répertoire, sans inclure son chemin d’accès complet.
Returns:
getDirectoryPath
public String getDirectoryPath()
Obtient le chemin d’accès de ce répertoire, sans inclure le nom de la ressource elle-même.
Returns:
getDirectoryUrl
public String getDirectoryUrl()
Obtient l’URL du répertoire représenté par ce client sur le service Data Lake.
Returns:
getFileAsyncClient
public DataLakeFileAsyncClient getFileAsyncClient(String fileName)
Crée un objet DataLakeFileAsyncClient en concaténant fileName à la fin de l’URL de DataLakeDirectoryAsyncClient. Le nouveau DataLakeFileAsyncClient utilise le même pipeline de stratégie de requête que le DataLakeDirectoryAsyncClient.
Exemples de code
DataLakeFileAsyncClient dataLakeFileClient = client.getFileAsyncClient(fileName);
Parameters:
String représentant le nom du fichier.
Returns:
getSubdirectoryAsyncClient
public DataLakeDirectoryAsyncClient getSubdirectoryAsyncClient(String subdirectoryName)
Crée un objet DataLakeDirectoryAsyncClient en concaténant subdirectoryName à la fin de l’URL de DataLakeDirectoryAsyncClient. Le nouveau DataLakeDirectoryAsyncClient utilise le même pipeline de stratégie de requête que le DataLakeDirectoryAsyncClient.
Exemples de code
DataLakeDirectoryAsyncClient dataLakeDirectoryClient = client.getSubdirectoryAsyncClient(directoryName);
Parameters:
String représentant le nom du sous-répertoire.
Returns:
listPaths
public PagedFlux
Retourne un serveur de publication réactif qui émet tous les fichiers/répertoires de ce répertoire paresseusement si nécessaire. Pour plus d’informations, consultez Azure Docs.
Exemples de code
client.listPaths().subscribe(path -> System.out.printf("Name: %s%n", path.getName()));
Returns:
listPaths
public PagedFlux
Retourne un serveur de publication réactif émettant tous les fichiers/répertoires de ce répertoire paresseusement si nécessaire. Pour plus d’informations, consultez Azure Docs.
Exemples de code
client.listPaths(false, false, 10)
.subscribe(path -> System.out.printf("Name: %s%n", path.getName()));
Parameters:
Returns:
rename
public Mono
Déplace le répertoire vers un autre emplacement dans le système de fichiers. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeDirectoryAsyncClient renamedClient = client.rename(fileSystemName, destinationPath).block();
System.out.println("Directory Client has been renamed");
Parameters:
null pour le système de fichiers actuel.
Returns:
renameWithResponse
public Mono
Déplace le répertoire vers un autre emplacement dans le système de fichiers. Pour plus d’informations, consultez Azure Docs.
Exemples de code
DataLakeRequestConditions sourceRequestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
DataLakeRequestConditions destinationRequestConditions = new DataLakeRequestConditions();
DataLakeDirectoryAsyncClient newRenamedClient = client.renameWithResponse(fileSystemName, destinationPath,
sourceRequestConditions, destinationRequestConditions).block().getValue();
System.out.println("Directory Client has been renamed");
Parameters:
null pour le système de fichiers actuel.
Returns:
S’applique à
Azure SDK for Java