Modifier and Type | Method and Description |
---|---|
protected FileInputFormat.FileBaseStatistics |
FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats,
Path filePath,
FileSystem fs,
ArrayList<FileStatus> files) |
Modifier and Type | Class and Description |
---|---|
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 . |
Modifier and Type | Method and Description |
---|---|
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 uri) |
FileSystem |
SafetyNetWrapperFileSystem.getWrappedDelegate() |
Modifier and Type | Method and Description |
---|---|
Path |
Path.makeQualified(FileSystem fs)
Returns a qualified path object.
|
Constructor and Description |
---|
SafetyNetWrapperFileSystem(FileSystem unsafeFileSystem,
SafetyNetCloseableRegistry registry) |
Modifier and Type | Class and 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. |
Constructor and Description |
---|
LocalFileStatus(File f,
FileSystem fs)
Creates a
LocalFileStatus object from a given File object. |
Modifier and Type | Method and Description |
---|---|
protected FileSystem |
AbstractFileStateHandle.getFileSystem()
Deprecated.
Gets the file system that stores the file state.
|
Constructor and Description |
---|
FileSystemBlobStore(FileSystem fileSystem,
String storagePath) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopFileSystem
Concrete implementation of the
FileSystem base class for the Hadoop File System. |
Modifier and Type | Class and Description |
---|---|
class |
MapRFileSystem
Concrete implementation of the
FileSystem base class for the MapR
file system. |
Constructor and Description |
---|
FsNegativeRunningJobsRegistry(FileSystem fileSystem,
Path workingDirectory)
Creates a new registry that writes its files to the given FileSystem at
the given working directory path.
|
Modifier and Type | Method and Description |
---|---|
protected Path |
FsSavepointStreamFactory.createBasePath(FileSystem fs,
Path checkpointDirectory,
JobID jobID) |
protected Path |
FsCheckpointStreamFactory.createBasePath(FileSystem fs,
Path checkpointDirectory,
JobID jobID) |
Constructor and Description |
---|
FsCheckpointStateOutputStream(Path basePath,
FileSystem fs,
int bufferSize,
int localStateThreshold) |
Modifier and Type | Method and Description |
---|---|
static boolean |
FileUtils.deletePathIfEmpty(FileSystem fileSystem,
Path path)
Deletes the path if it is empty.
|
Modifier and Type | Field and Description |
---|---|
protected FileSystem |
YarnHighAvailabilityServices.flinkFileSystem
The Flink FileSystem object that represent the HDFS used by YARN
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.