public class HadoopFsFactory extends Object implements FileSystemFactory
This factory calls Hadoop's mechanism to find a file system implementation for a given file
system scheme (a FileSystem
) and wraps it as a Flink file system (a
FileSystem
).
Constructor and Description |
---|
HadoopFsFactory() |
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.
|
String |
getScheme()
Gets the scheme of the file system created by this factory.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getClassLoader
public String getScheme()
FileSystemFactory
getScheme
in interface FileSystemFactory
public void configure(Configuration config)
Plugin
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.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.