org.apache.flink.fs.azurefs

Class AbstractAzureFSFactory

java.lang.Object

org.apache.flink.fs.azurefs.AbstractAzureFSFactory

All Implemented Interfaces:

FileSystemFactory, Plugin

Direct Known Subclasses:

AzureBlobStorageFSFactory, AzureDataLakeStoreGen2FSFactory, SecureAzureBlobStorageFSFactory, SecureAzureDataLakeStoreGen2FSFactory

public abstract class AbstractAzureFSFactory
extends Object
implements FileSystemFactory

Abstract factory for AzureFS. Subclasses override to specify the correct scheme (wasb / wasbs / abfs/ abfss). Based on Azure HDFS support in the hadoop-azure module.

Constructor Summary

Constructors

Constructor and Description
AbstractAzureFSFactory()

Method Summary

Modifier and Type	Method and Description
void	configure(Configuration config) Optional method for plugins to pick up settings from the configuration.
FileSystem	create(URI fsUri) Creates a new file system for the given file system URI.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.core.fs.FileSystemFactory

getScheme

Methods inherited from interface org.apache.flink.core.plugin.Plugin

getClassLoader

Constructor Detail

AbstractAzureFSFactory

public AbstractAzureFSFactory()

Method Detail

configure

public void configure(Configuration config)

Description copied from interface: Plugin

Optional method for plugins to pick up settings from the configuration.

Specified by:

configure in interface Plugin

Parameters:

config - The configuration to apply to the plugin.

create

public FileSystem create(URI fsUri)
                  throws IOException

Description copied from interface: FileSystemFactory

Creates a new file system for the given file system URI. The URI describes the type of file system (via its scheme) and optionally the authority (for example the host) of the file system.

Specified by:

create in interface FileSystemFactory

Parameters:

fsUri - The URI that describes the file system.

Returns:

A new instance of the specified file system.

Throws:

IOException - Thrown if the file system could not be instantiated.