DataLakeDirectoryAsyncClient Klasse
- java.
lang. Object - com.
azure. storage. file. datalake. DataLakePathAsyncClient - com.
azure. storage. file. datalake. DataLakeDirectoryAsyncClient
- com.
- com.
public final class DataLakeDirectoryAsyncClient
extends DataLakePathAsyncClient
Diese Klasse stellt einen Client bereit, der Verzeichnisvorgänge für Azure Storage Data Lake enthält. Zu den von diesem Client bereitgestellten Vorgängen gehören das Erstellen eines Verzeichnisses, das Löschen eines Verzeichnisses, das Umbenennen eines Verzeichnisses, das Festlegen von Metadaten und HTTP-Headern, das Festlegen und Abrufen der Zugriffssteuerung, das Abrufen von Eigenschaften sowie das Erstellen und Löschen von Dateien und Unterverzeichnissen.
Dieser Client wird über DataLakePathClientBuilder instanziiert oder über getDirectoryAsyncClient(String directoryName)abgerufen.
Weitere Informationen finden Sie in der Azure-Dokumentation .
Methodenzusammenfassung
Geerbte Methoden von DataLakePathAsyncClient
Geerbte Methoden von java.lang.Object
Details zur Methode
createFile
public Mono
Erstellt eine neue Datei in einem Verzeichnis. Standardmäßig überschreibt diese Methode keine vorhandene Datei. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
DataLakeFileAsyncClient fileClient = client.createFile(fileName).block();
Parameters:
Returns:
createFile
public Mono
Erstellt eine neue Datei in einem Verzeichnis. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
boolean overwrite = false; /* Default value. */
DataLakeFileAsyncClient fClient = client.createFile(fileName, overwrite).block();
Parameters:
Returns:
createFileIfNotExists
public Mono
Erstellt eine neue Datei in einem Verzeichnis, wenn sie nicht vorhanden ist. Standardmäßig überschreibt diese Methode keine vorhandene Datei. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
DataLakeFileAsyncClient fileClient = client.createFileIfNotExists(fileName).block();
Parameters:
Returns:
createFileIfNotExistsWithResponse
public Mono
Erstellt eine neue Datei in einem Verzeichnis, falls sie nicht vorhanden ist. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Erstellt eine neue Datei in einem Verzeichnis. Wenn bereits eine Datei mit demselben Namen vorhanden ist, wird die Datei überschrieben. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Erstellt eine neue Datei in einem Verzeichnis. Wenn bereits eine Datei mit demselben Namen vorhanden ist, wird die Datei überschrieben. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Erstellt ein neues Unterverzeichnis innerhalb eines Verzeichnisses. Standardmäßig überschreibt diese Methode kein vorhandenes Unterverzeichnis. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
DataLakeDirectoryAsyncClient directoryClient = client.createSubdirectory(directoryName).block();
Parameters:
Returns:
createSubdirectory
public Mono
Erstellt ein neues Unterverzeichnis innerhalb eines Verzeichnisses. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
boolean overwrite = false; /* Default value. */
DataLakeDirectoryAsyncClient dClient = client.createSubdirectory(directoryName, overwrite).block();
Parameters:
Returns:
createSubdirectoryIfNotExists
public Mono
Erstellt ein neues Unterverzeichnis innerhalb eines Verzeichnisses, sofern es nicht vorhanden ist. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
DataLakeDirectoryAsyncClient subdirectoryClient = client.createSubdirectoryIfNotExists(directoryName).block();
Parameters:
Returns:
createSubdirectoryIfNotExistsWithResponse
public Mono
Erstellt ein neues Unterverzeichnis innerhalb eines Verzeichnisses, sofern es nicht vorhanden ist. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Erstellt ein neues Unterverzeichnis innerhalb eines Verzeichnisses. Wenn bereits ein Unterverzeichnis mit demselben Namen vorhanden ist, wird das Unterverzeichnis überschrieben. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Erstellt ein neues Unterverzeichnis innerhalb eines Verzeichnisses. Wenn bereits ein Unterverzeichnis mit demselben Namen vorhanden ist, wird das Unterverzeichnis überschrieben. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Löscht ein Verzeichnis.
Codebeispiele
client.delete().subscribe(response ->
System.out.println("Delete request completed"));
Weitere Informationen finden Sie in der Azure-Dokumentation.
Returns:
deleteFile
public Mono
Löscht die angegebene Datei im Dateisystem. Wenn die Datei nicht vorhanden ist, schlägt der Vorgang fehl. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
client.deleteFile(fileName).subscribe(response ->
System.out.println("Delete request completed"));
Parameters:
Returns:
deleteFileIfExists
public Mono
Löscht die angegebene Datei im Dateisystem, sofern sie vorhanden ist. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
client.deleteFileIfExists(fileName).subscribe(deleted -> {
if (deleted) {
System.out.println("successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Parameters:
Returns:
true gibt an, dass die angegebene Datei erfolgreich gelöscht wurde, gibt an, false dass die angegebene Datei nicht vorhanden war.deleteFileIfExistsWithResponse
public Mono
Löscht die angegebene Datei im Verzeichnis, sofern sie vorhanden ist. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Löscht die angegebene Datei im Verzeichnis. Wenn die Datei nicht vorhanden ist, schlägt der Vorgang fehl. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
client.deleteFileWithResponse(fileName, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Parameters:
Returns:
deleteIfExists
public Mono
Löscht ein Verzeichnis, sofern es vorhanden ist.
Codebeispiele
client.deleteIfExists().subscribe(deleted -> {
if (deleted) {
System.out.println("Successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Weitere Informationen finden Sie in der Azure-Dokumentation.
Overrides:
DataLakeDirectoryAsyncClient.deleteIfExists()Returns:
true gibt an, dass das Verzeichnis erfolgreich gelöscht wurde, gibt an, true dass das Verzeichnis nicht vorhanden war.deleteIfExistsWithResponse
public Mono
Löscht ein Verzeichnis, sofern es vorhanden ist.
Codebeispiele
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.");
}
});
Weitere Informationen finden Sie in der Azure-Dokumentation.
Overrides:
DataLakeDirectoryAsyncClient.deleteIfExistsWithResponse(DataLakePathDeleteOptions options)Parameters:
Returns:
deleteRecursively
public Mono
Löscht rekursiv ein Verzeichnis und alle Inhalte innerhalb des Verzeichnisses.
Codebeispiele
client.deleteRecursively().subscribe(response ->
System.out.println("Delete request completed"));
Weitere Informationen finden Sie in der Azure-Dokumentation.
Returns:
deleteRecursivelyWithResponse
public Mono
Löscht rekursiv ein Verzeichnis und alle Inhalte innerhalb des Verzeichnisses.
Codebeispiele
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
client.deleteWithResponse(recursive, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Weitere Informationen finden Sie in der Azure-Dokumentation.
Parameters:
Returns:
deleteSubdirectory
public Mono
Löscht das angegebene Unterverzeichnis im Verzeichnis. Wenn das Unterverzeichnis nicht vorhanden ist oder nicht leer ist, schlägt der Vorgang fehl. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
client.deleteSubdirectory(directoryName).subscribe(response ->
System.out.println("Delete request completed"));
Parameters:
Returns:
deleteSubdirectoryIfExists
public Mono
Löscht das angegebene Unterverzeichnis im Verzeichnis, sofern es vorhanden ist. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
client.deleteSubdirectoryIfExists(directoryName).subscribe(deleted -> {
if (deleted) {
System.out.println("Successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Parameters:
Returns:
true gibt an, dass das Unterverzeichnis gelöscht wurde.
false gibt an, dass das angegebene Unterverzeichnis nicht vorhanden ist.deleteSubdirectoryIfExistsWithResponse
public Mono
Löscht das angegebene Unterverzeichnis im Verzeichnis, sofern es vorhanden ist. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Löscht das angegebene Unterverzeichnis im Verzeichnis. Wenn das Unterverzeichnis nicht vorhanden ist oder nicht leer ist, schlägt der Vorgang fehl. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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
Löscht ein Verzeichnis.
Codebeispiele
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
client.deleteWithResponse(recursive, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Weitere Informationen finden Sie in der Azure-Dokumentation.
Parameters:
Returns:
getCustomerProvidedKeyAsyncClient
public DataLakeDirectoryAsyncClient getCustomerProvidedKeyAsyncClient(CustomerProvidedKey customerProvidedKey)
Erstellt einen neuen DataLakeDirectoryAsyncClient mit dem angegebenen customerProvidedKey.
Overrides:
DataLakeDirectoryAsyncClient.getCustomerProvidedKeyAsyncClient(CustomerProvidedKey customerProvidedKey)Parameters:
null , um keinen vom Kunden bereitgestellten Schlüssel zu verwenden.
Returns:
customerProvidedKey.getDirectoryName
public String getDirectoryName()
Ruft den Namen dieses Verzeichnisses ab, ohne den vollständigen Pfad zu enthalten.
Returns:
getDirectoryPath
public String getDirectoryPath()
Ruft den Pfad dieses Verzeichnisses ab, ohne den Namen der Ressource selbst.
Returns:
getDirectoryUrl
public String getDirectoryUrl()
Ruft die URL des Verzeichnisses ab, das von diesem Client im Data Lake-Dienst dargestellt wird.
Returns:
getFileAsyncClient
public DataLakeFileAsyncClient getFileAsyncClient(String fileName)
Erstellt ein neues DataLakeFileAsyncClient-Objekt, indem fileName mit dem Ende der DataLakeDirectoryAsyncClient-URL verkettet wird. Der neue DataLakeFileAsyncClient verwendet dieselbe Anforderungsrichtlinienpipeline wie dataLakeDirectoryAsyncClient.
Codebeispiele
DataLakeFileAsyncClient dataLakeFileClient = client.getFileAsyncClient(fileName);
Parameters:
String , der den Namen der Datei darstellt.
Returns:
getSubdirectoryAsyncClient
public DataLakeDirectoryAsyncClient getSubdirectoryAsyncClient(String subdirectoryName)
Erstellt ein neues DataLakeDirectoryAsyncClient-Objekt, indem subdirectoryName an das Ende der DataLakeDirectoryAsyncClient-URL verkettet wird. Das neue DataLakeDirectoryAsyncClient verwendet dieselbe Anforderungsrichtlinienpipeline wie dataLakeDirectoryAsyncClient.
Codebeispiele
DataLakeDirectoryAsyncClient dataLakeDirectoryClient = client.getSubdirectoryAsyncClient(directoryName);
Parameters:
String , der den Namen des Unterverzeichnisses darstellt.
Returns:
listPaths
public PagedFlux
Gibt einen reaktiven Verleger zurück, der alle Dateien/Verzeichnisse in diesem Verzeichnis nach Bedarf lazily ausgibt. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
client.listPaths().subscribe(path -> System.out.printf("Name: %s%n", path.getName()));
Returns:
listPaths
public PagedFlux
Gibt einen reaktiven Verleger zurück, der alle Dateien/Verzeichnisse in diesem Verzeichnis nach Bedarf verzögert ausgibt. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
client.listPaths(false, false, 10)
.subscribe(path -> System.out.printf("Name: %s%n", path.getName()));
Parameters:
Returns:
rename
public Mono
Verschiebt das Verzeichnis an einen anderen Speicherort im Dateisystem. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
DataLakeDirectoryAsyncClient renamedClient = client.rename(fileSystemName, destinationPath).block();
System.out.println("Directory Client has been renamed");
Parameters:
null für das aktuelle Dateisystem.
Returns:
renameWithResponse
public Mono
Verschiebt das Verzeichnis an einen anderen Speicherort im Dateisystem. Weitere Informationen finden Sie in der Azure-Dokumentation.
Codebeispiele
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 für das aktuelle Dateisystem.
Returns:
Gilt für:
Azure SDK for Java