Uses of Class
org.apache.flink.core.fs.FileSystem

Packages that use FileSystem

Package	Description
org.apache.flink.api.common.io
org.apache.flink.core.fs
org.apache.flink.core.fs.local

Uses of FileSystem in org.apache.flink.api.common.io

Methods in org.apache.flink.api.common.io with parameters of type FileSystem

Modifier and Type	Method	Description
protected FileInputFormat.FileBaseStatistics	FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats, Path filePath, FileSystem fs, ArrayList<FileStatus> files)

Uses of FileSystem in org.apache.flink.core.fs

Subclasses of FileSystem in org.apache.flink.core.fs

Modifier and Type	Class	Description
class	LimitedConnectionsFileSystem	A file system that limits the number of concurrently open input streams, output streams, and total streams for a target file system.
class	SafetyNetWrapperFileSystem	This is a WrappingProxy around FileSystem which (i) wraps all opened streams as ClosingFSDataInputStream or ClosingFSDataOutputStream and (ii) registers them to a SafetyNetCloseableRegistry.

Methods in org.apache.flink.core.fs that return FileSystem

Modifier and Type	Method	Description
FileSystem	ConnectionLimitingFactory.create(URI fsUri)
FileSystem	FileSystemFactory.create(URI fsUri)	Creates a new file system for the given file system URI.
FileSystem	PluginFileSystemFactory.create(URI fsUri)
static FileSystem	FileSystem.get(URI uri)	Returns a reference to the FileSystem instance for accessing the file system identified by the given URI.
FileSystem	Path.getFileSystem()	Returns the FileSystem that owns this Path.
static FileSystem	FileSystem.getLocalFileSystem()	Returns a reference to the FileSystem instance for accessing the local file system.
static FileSystem	FileSystem.getUnguardedFileSystem(URI fsUri)
FileSystem	SafetyNetWrapperFileSystem.getWrappedDelegate()

Methods in org.apache.flink.core.fs with parameters of type FileSystem

Modifier and Type	Method	Description
static Path	EntropyInjector.addEntropy(FileSystem fs, Path path)	Handles entropy injection across regular and entropy-aware file systems.
static OutputStreamAndPath	EntropyInjector.createEntropyAware(FileSystem fs, Path path, FileSystem.WriteMode writeMode)	Handles entropy injection across regular and entropy-aware file systems.
static boolean	EntropyInjector.isEntropyInjecting(FileSystem fs, Path target)
Path	Path.makeQualified(FileSystem fs)	Returns a qualified path object.
static Path	EntropyInjector.removeEntropyMarkerIfPresent(FileSystem fs, Path path)	Removes the entropy marker string from the path, if the given file system is an entropy-injecting file system (implements EntropyInjectingFileSystem) and the entropy marker key is present.

Constructors in org.apache.flink.core.fs with parameters of type FileSystem

Constructor	Description
LimitedConnectionsFileSystem(FileSystem originalFs, int maxNumOpenStreamsTotal)	Creates a new output connection limiting file system.
LimitedConnectionsFileSystem(FileSystem originalFs, int maxNumOpenStreamsTotal, int maxNumOpenOutputStreams, int maxNumOpenInputStreams, long streamOpenTimeout, long streamInactivityTimeout)	Creates a new output connection limiting file system, limiting input and output streams with potentially different quotas.
LimitedConnectionsFileSystem(FileSystem originalFs, int maxNumOpenStreamsTotal, long streamOpenTimeout, long streamInactivityTimeout)	Creates a new output connection limiting file system.
SafetyNetWrapperFileSystem(FileSystem unsafeFileSystem, SafetyNetCloseableRegistry registry)

Uses of FileSystem in org.apache.flink.core.fs.local

Subclasses of FileSystem in org.apache.flink.core.fs.local

Modifier and Type	Class	Description
class	LocalFileSystem	The class LocalFileSystem is an implementation of the FileSystem interface for the local file system of the machine where the JVM runs.

Methods in org.apache.flink.core.fs.local that return FileSystem

Modifier and Type	Method	Description
FileSystem	LocalFileSystemFactory.create(URI fsUri)

Constructors in org.apache.flink.core.fs.local with parameters of type FileSystem

Constructor	Description
LocalFileStatus(File f, FileSystem fs)	Creates a LocalFileStatus object from a given File object.