Package org.apache.flink.fs.azurefs

Class AbstractAzureFSFactory

java.lang.Object

org.apache.flink.fs.azurefs.AbstractAzureFSFactory

All Implemented Interfaces:

org.apache.flink.core.fs.FileSystemFactory, org.apache.flink.core.plugin.Plugin

Direct Known Subclasses:

AzureBlobStorageFSFactory, AzureDataLakeStoreGen2FSFactory, SecureAzureBlobStorageFSFactory, SecureAzureDataLakeStoreGen2FSFactory

public abstract class AbstractAzureFSFactory
extends Object
implements org.apache.flink.core.fs.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	Description
AbstractAzureFSFactory()

Method Summary

Modifier and Type	Method	Description
void	configure(org.apache.flink.configuration.Configuration config)
org.apache.flink.core.fs.FileSystem	create(URI fsUri)

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(org.apache.flink.configuration.Configuration config)

Specified by:

configure in interface org.apache.flink.core.plugin.Plugin

create

public org.apache.flink.core.fs.FileSystem create(URI fsUri)
                                           throws IOException

Specified by:

create in interface org.apache.flink.core.fs.FileSystemFactory

Throws:

IOException