@Internal public class ConnectionLimitingFactory extends Object implements FileSystemFactory
LimitedConnectionsFileSystem
to a file system.Modifier and Type | Method and Description |
---|---|
void |
configure(Configuration config)
Applies the given configuration to this factory.
|
FileSystem |
create(URI fsUri)
Creates a new file system for the given file system URI.
|
static FileSystemFactory |
decorateIfLimited(FileSystemFactory factory,
String scheme,
Configuration config)
Decorates the given factory for a
ConnectionLimitingFactory , if the given
configuration configured connection limiting for the given file system scheme. |
String |
getScheme()
Gets the scheme of the file system created by this factory.
|
public String getScheme()
FileSystemFactory
getScheme
in interface FileSystemFactory
public void configure(Configuration config)
FileSystemFactory
FileSystemFactory.create(URI)
should take the configuration into
account.configure
in interface FileSystemFactory
config
- The configuration to apply.public FileSystem create(URI fsUri) throws IOException
FileSystemFactory
create
in interface FileSystemFactory
fsUri
- The URI that describes the file system.IOException
- Thrown if the file system could not be instantiated.public static FileSystemFactory decorateIfLimited(FileSystemFactory factory, String scheme, Configuration config)
ConnectionLimitingFactory
, if the given
configuration configured connection limiting for the given file system scheme.
Otherwise, it returns the given factory as is.factory
- The factory to potentially decorate.scheme
- The file scheme for which to check the configuration.config
- The configurationCopyright © 2014–2019 The Apache Software Foundation. All rights reserved.