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
Essa classe fornece um cliente que contém operações de diretório para o Azure Storage Data Lake. As operações fornecidas por esse cliente incluem criar um diretório, excluir um diretório, renomear um diretório, definir metadados e cabeçalhos http, definir e recuperar o controle de acesso, obter propriedades e criar e excluir arquivos e subdiretórios.
Esse cliente é instanciado por meio DataLakePathClientBuilder de ou recuperado por meio de getDirectoryAsyncClient(String directoryName).
Consulte o Azure Docs para obter mais informações.
Resumo do método
Métodos herdados de DataLakePathAsyncClient
Métodos herdados de java.lang.Object
Detalhes do método
createFile
public Mono
Cria um novo arquivo em um diretório. Por padrão, esse método não substituirá um arquivo existente. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
DataLakeFileAsyncClient fileClient = client.createFile(fileName).block();
Parameters:
Returns:
createFile
public Mono
Cria um novo arquivo em um diretório. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
boolean overwrite = false; /* Default value. */
DataLakeFileAsyncClient fClient = client.createFile(fileName, overwrite).block();
Parameters:
Returns:
createFileIfNotExists
public Mono
Cria um novo arquivo em um diretório se ele não existir. Por padrão, esse método não substituirá um arquivo existente. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
DataLakeFileAsyncClient fileClient = client.createFileIfNotExists(fileName).block();
Parameters:
Returns:
createFileIfNotExistsWithResponse
public Mono
Cria um novo arquivo em um diretório se ele não existir. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Cria um novo arquivo em um diretório. Se já existir um arquivo com o mesmo nome, o arquivo será substituído. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Cria um novo arquivo em um diretório. Se já existir um arquivo com o mesmo nome, o arquivo será substituído. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Cria um novo subdiretório em um diretório. Por padrão, esse método não substituirá um subdiretório existente. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
DataLakeDirectoryAsyncClient directoryClient = client.createSubdirectory(directoryName).block();
Parameters:
Returns:
createSubdirectory
public Mono
Cria um novo subdiretório em um diretório. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
boolean overwrite = false; /* Default value. */
DataLakeDirectoryAsyncClient dClient = client.createSubdirectory(directoryName, overwrite).block();
Parameters:
Returns:
createSubdirectoryIfNotExists
public Mono
Cria um novo subdiretório em um diretório se ele não existir. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
DataLakeDirectoryAsyncClient subdirectoryClient = client.createSubdirectoryIfNotExists(directoryName).block();
Parameters:
Returns:
createSubdirectoryIfNotExistsWithResponse
public Mono
Cria um novo subdiretório em um diretório se ele não existir. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Cria um novo subdiretório em um diretório. Se já existir um subdiretório com o mesmo nome, o subdiretório será substituído. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Cria um novo subdiretório em um diretório. Se já existir um subdiretório com o mesmo nome, o subdiretório será substituído. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Exclui um diretório.
Exemplos de código
client.delete().subscribe(response ->
System.out.println("Delete request completed"));
Para obter mais informações, consulte o Azure Docs
Returns:
deleteFile
public Mono
Exclui o arquivo especificado no sistema de arquivos. Se o arquivo não existir, a operação falhará. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
client.deleteFile(fileName).subscribe(response ->
System.out.println("Delete request completed"));
Parameters:
Returns:
deleteFileIfExists
public Mono
Exclui o arquivo especificado no sistema de arquivos se ele existir. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
client.deleteFileIfExists(fileName).subscribe(deleted -> {
if (deleted) {
System.out.println("successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Parameters:
Returns:
true indica que o arquivo especificado foi excluído com êxito, false indica que o arquivo especificado não existia.deleteFileIfExistsWithResponse
public Mono
Exclui o arquivo especificado no diretório se ele existir. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Exclui o arquivo especificado no diretório. Se o arquivo não existir, a operação falhará. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
client.deleteFileWithResponse(fileName, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Parameters:
Returns:
deleteIfExists
public Mono
Exclui um diretório se ele existir.
Exemplos de código
client.deleteIfExists().subscribe(deleted -> {
if (deleted) {
System.out.println("Successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Para obter mais informações, consulte o Azure Docs
Overrides:
DataLakeDirectoryAsyncClient.deleteIfExists()Returns:
true indica que o diretório foi excluído com êxito, true indica que o diretório não existia.deleteIfExistsWithResponse
public Mono
Exclui um diretório se ele existir.
Exemplos de código
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.");
}
});
Para obter mais informações, consulte o Azure Docs
Overrides:
DataLakeDirectoryAsyncClient.deleteIfExistsWithResponse(DataLakePathDeleteOptions options)Parameters:
Returns:
deleteRecursively
public Mono
Exclui recursivamente um diretório e todo o conteúdo dentro do diretório.
Exemplos de código
client.deleteRecursively().subscribe(response ->
System.out.println("Delete request completed"));
Para obter mais informações, consulte o Azure Docs
Returns:
deleteRecursivelyWithResponse
public Mono
Exclui recursivamente um diretório e todo o conteúdo dentro do diretório.
Exemplos de código
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
client.deleteWithResponse(recursive, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Para obter mais informações, consulte o Azure Docs
Parameters:
Returns:
deleteSubdirectory
public Mono
Exclui o subdiretório especificado no diretório. Se o subdiretório não existir ou não estiver vazio, a operação falhará. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
client.deleteSubdirectory(directoryName).subscribe(response ->
System.out.println("Delete request completed"));
Parameters:
Returns:
deleteSubdirectoryIfExists
public Mono
Exclui o subdiretório especificado no diretório se ele existir. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
client.deleteSubdirectoryIfExists(directoryName).subscribe(deleted -> {
if (deleted) {
System.out.println("Successfully deleted.");
} else {
System.out.println("Does not exist.");
}
});
Parameters:
Returns:
true indica que o subdiretório foi excluído.
false indica que o subdiretório especificado não existe.deleteSubdirectoryIfExistsWithResponse
public Mono
Exclui o subdiretório especificado no diretório se ele existir. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Exclui o subdiretório especificado no diretório. Se o subdiretório não existir ou não estiver vazio, a operação falhará. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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
Exclui um diretório.
Exemplos de código
DataLakeRequestConditions requestConditions = new DataLakeRequestConditions()
.setLeaseId(leaseId);
boolean recursive = false; // Default value
client.deleteWithResponse(recursive, requestConditions)
.subscribe(response -> System.out.println("Delete request completed"));
Para obter mais informações, consulte o Azure Docs
Parameters:
Returns:
getCustomerProvidedKeyAsyncClient
public DataLakeDirectoryAsyncClient getCustomerProvidedKeyAsyncClient(CustomerProvidedKey customerProvidedKey)
Cria um novo DataLakeDirectoryAsyncClient com o customerProvidedKey especificado.
Overrides:
DataLakeDirectoryAsyncClient.getCustomerProvidedKeyAsyncClient(CustomerProvidedKey customerProvidedKey)Parameters:
null para usar nenhuma chave fornecida pelo cliente.
Returns:
customerProvidedKey.getDirectoryName
public String getDirectoryName()
Obtém o nome desse diretório, sem incluir seu caminho completo.
Returns:
getDirectoryPath
public String getDirectoryPath()
Obtém o caminho desse diretório, sem incluir o nome do recurso em si.
Returns:
getDirectoryUrl
public String getDirectoryUrl()
Obtém a URL do diretório representado por esse cliente no serviço Data Lake.
Returns:
getFileAsyncClient
public DataLakeFileAsyncClient getFileAsyncClient(String fileName)
Cria um novo objeto DataLakeFileAsyncClient concatenando fileName ao final da URL de DataLakeDirectoryAsyncClient. O novo DataLakeFileAsyncClient usa o mesmo pipeline de política de solicitação que o DataLakeDirectoryAsyncClient.
Exemplos de código
DataLakeFileAsyncClient dataLakeFileClient = client.getFileAsyncClient(fileName);
Parameters:
String que representa o nome do arquivo.
Returns:
getSubdirectoryAsyncClient
public DataLakeDirectoryAsyncClient getSubdirectoryAsyncClient(String subdirectoryName)
Cria um novo objeto DataLakeDirectoryAsyncClient concatenando subdirectoryName ao final da URL de DataLakeDirectoryAsyncClient. O novo DataLakeDirectoryAsyncClient usa o mesmo pipeline de política de solicitação que o DataLakeDirectoryAsyncClient.
Exemplos de código
DataLakeDirectoryAsyncClient dataLakeDirectoryClient = client.getSubdirectoryAsyncClient(directoryName);
Parameters:
String que representa o nome do subdiretório.
Returns:
listPaths
public PagedFlux
Retorna um Publicador reativo emitindo todos os arquivos/diretórios neste diretório de forma preguiçosa, conforme necessário. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
client.listPaths().subscribe(path -> System.out.printf("Name: %s%n", path.getName()));
Returns:
listPaths
public PagedFlux
Retorna um Publicador reativo emitindo todos os arquivos/diretórios neste diretório de forma preguiçosa, conforme necessário. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
client.listPaths(false, false, 10)
.subscribe(path -> System.out.printf("Name: %s%n", path.getName()));
Parameters:
Returns:
rename
public Mono
Move o diretório para outro local dentro do sistema de arquivos. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
DataLakeDirectoryAsyncClient renamedClient = client.rename(fileSystemName, destinationPath).block();
System.out.println("Directory Client has been renamed");
Parameters:
null para o sistema de arquivos atual.
Returns:
renameWithResponse
public Mono
Move o diretório para outro local dentro do sistema de arquivos. Para obter mais informações, consulte o Azure Docs.
Exemplos de código
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 para o sistema de arquivos atual.
Returns:
Aplica-se a
Azure SDK for Java