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

Packages that use Path

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

Uses of Path in org.apache.flink.api.common.cache

Constructor parameters in org.apache.flink.api.common.cache with type arguments of type Path

Constructor	Description
DistributedCache(Map<String,Future<Path>> cacheCopyTasks)

Uses of Path in org.apache.flink.api.common.functions.util

Constructor parameters in org.apache.flink.api.common.functions.util with type arguments of type Path

Constructor	Description
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, org.apache.flink.metrics.groups.OperatorMetricGroup metrics)
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, org.apache.flink.metrics.groups.OperatorMetricGroup metrics, JobID jobID)

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

Fields in org.apache.flink.api.common.io declared as Path

Modifier and Type	Field	Description
protected Path	FileInputFormat.filePath	Deprecated. Please override FileInputFormat.supportsMultiPaths() and use FileInputFormat.getFilePaths() and FileInputFormat.setFilePaths(Path...).
protected Path	FileOutputFormat.outputFilePath	The path of the file to be written.

Methods in org.apache.flink.api.common.io that return Path

Modifier and Type	Method	Description
Path	FileInputFormat.getFilePath()	Deprecated. Please use getFilePaths() instead.
Path[]	FileInputFormat.getFilePaths()	Returns the paths of all files to be read by the FileInputFormat.
Path	FileOutputFormat.getOutputFilePath()

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

Modifier and Type	Method	Description
boolean	FilePathFilter.DefaultFilter.filterPath(Path filePath)
abstract boolean	FilePathFilter.filterPath(Path filePath)	Returns true if the filePath given is to be ignored when processing a directory, e.g.
boolean	GlobFilePathFilter.filterPath(Path filePath)
protected FileInputFormat.FileBaseStatistics	FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats, Path[] filePaths, ArrayList<FileStatus> files)
protected FileInputFormat.FileBaseStatistics	FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats, Path filePath, FileSystem fs, ArrayList<FileStatus> files)
void	FileInputFormat.setFilePath(Path filePath)	Sets a single path of a file to be read.
void	FileInputFormat.setFilePaths(Path... filePaths)	Sets multiple paths of files to be read.
void	FileOutputFormat.setOutputFilePath(Path path)

Constructors in org.apache.flink.api.common.io with parameters of type Path

Constructor	Description
DelimitedInputFormat(Path filePath, Configuration configuration)
FileInputFormat(Path filePath)
FileOutputFormat(Path outputPath)
GenericCsvInputFormat(Path filePath)

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

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

Modifier and Type	Method	Description
static Path	EntropyInjector.addEntropy(FileSystem fs, Path path)	Handles entropy injection across regular and entropy-aware file systems.
static Path	Path.fromLocalFile(File file)	Creates a path for the given local file.
Path	DuplicatingFileSystem.CopyRequest.getDestination()	The path where to duplicate the source file.
abstract Path	FileSystem.getHomeDirectory()	Returns the path of the user's home directory in this file system.
Path	LimitedConnectionsFileSystem.getHomeDirectory()
Path	SafetyNetWrapperFileSystem.getHomeDirectory()
Path	Path.getParent()	Returns the parent of a path, i.e., everything that precedes the last separator or null if at root.
Path	FileInputSplit.getPath()	Returns the path of the file containing this split's data.
Path	FileStatus.getPath()	Returns the corresponding Path to the FileStatus.
Path	DuplicatingFileSystem.CopyRequest.getSource()	The path of the source file to duplicate.
abstract Path	FileSystem.getWorkingDirectory()	Returns the path of the file system's current working directory.
Path	LimitedConnectionsFileSystem.getWorkingDirectory()
Path	SafetyNetWrapperFileSystem.getWorkingDirectory()
Path	Path.makeQualified(FileSystem fs)	Returns a qualified path object.
Path	OutputStreamAndPath.path()
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.
Path	Path.suffix(String suffix)	Adds a suffix to the final name in the path.

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

Modifier and Type	Method	Description
static Path	EntropyInjector.addEntropy(FileSystem fs, Path path)	Handles entropy injection across regular and entropy-aware file systems.
boolean	DuplicatingFileSystem.canFastDuplicate(Path source, Path destination)	Tells if we can perform duplicate/copy between given paths.
FSDataOutputStream	FileSystem.create(Path f, boolean overwrite)	Deprecated. Use FileSystem.create(Path, WriteMode) instead.
FSDataOutputStream	FileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)	Deprecated. Deprecated because not well supported across types of file systems.
abstract FSDataOutputStream	FileSystem.create(Path f, FileSystem.WriteMode overwriteMode)	Opens an FSDataOutputStream to a new file at the given path.
FSDataOutputStream	LimitedConnectionsFileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)	Deprecated.
FSDataOutputStream	LimitedConnectionsFileSystem.create(Path f, FileSystem.WriteMode overwriteMode)
FSDataOutputStream	SafetyNetWrapperFileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)
FSDataOutputStream	SafetyNetWrapperFileSystem.create(Path f, FileSystem.WriteMode overwrite)
static OutputStreamAndPath	EntropyInjector.createEntropyAware(FileSystem fs, Path path, FileSystem.WriteMode writeMode)	Handles entropy injection across regular and entropy-aware file systems.
abstract boolean	FileSystem.delete(Path f, boolean recursive)	Delete a file.
boolean	LimitedConnectionsFileSystem.delete(Path f, boolean recursive)
boolean	SafetyNetWrapperFileSystem.delete(Path f, boolean recursive)
boolean	FileSystem.exists(Path f)	Check if exists.
boolean	LimitedConnectionsFileSystem.exists(Path f)
boolean	SafetyNetWrapperFileSystem.exists(Path f)
abstract FileStatus	FileSystem.getFileStatus(Path f)	Return a file status object that represents the path.
FileStatus	LimitedConnectionsFileSystem.getFileStatus(Path f)
FileStatus	SafetyNetWrapperFileSystem.getFileStatus(Path f)
boolean	FileSystem.initOutPathDistFS(Path outPath, FileSystem.WriteMode writeMode, boolean createDirectory)	Initializes output directories on distributed file systems according to the given write mode.
boolean	SafetyNetWrapperFileSystem.initOutPathDistFS(Path outPath, FileSystem.WriteMode writeMode, boolean createDirectory)
boolean	FileSystem.initOutPathLocalFS(Path outPath, FileSystem.WriteMode writeMode, boolean createDirectory)	Initializes output directories on local file systems according to the given write mode.
boolean	SafetyNetWrapperFileSystem.initOutPathLocalFS(Path outPath, FileSystem.WriteMode writeMode, boolean createDirectory)
static boolean	EntropyInjector.isEntropyInjecting(FileSystem fs, Path target)
abstract FileStatus[]	FileSystem.listStatus(Path f)	List the statuses of the files/directories in the given path if the path is a directory.
FileStatus[]	LimitedConnectionsFileSystem.listStatus(Path f)
FileStatus[]	SafetyNetWrapperFileSystem.listStatus(Path f)
abstract boolean	FileSystem.mkdirs(Path f)	Make the given file and all non-existent parents into directories.
boolean	LimitedConnectionsFileSystem.mkdirs(Path f)
boolean	SafetyNetWrapperFileSystem.mkdirs(Path f)
static DuplicatingFileSystem.CopyRequest	DuplicatingFileSystem.CopyRequest.of(Path source, Path destination)	A factory method for creating a simple pair of source/destination.
abstract FSDataInputStream	FileSystem.open(Path f)	Opens an FSDataInputStream at the indicated Path.
abstract FSDataInputStream	FileSystem.open(Path f, int bufferSize)	Opens an FSDataInputStream at the indicated Path.
FSDataInputStream	LimitedConnectionsFileSystem.open(Path f)
FSDataInputStream	LimitedConnectionsFileSystem.open(Path f, int bufferSize)
RecoverableFsDataOutputStream	RecoverableWriter.open(Path path)	Opens a new recoverable stream to write to the given path.
FSDataInputStream	SafetyNetWrapperFileSystem.open(Path f)
FSDataInputStream	SafetyNetWrapperFileSystem.open(Path f, int bufferSize)
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.
abstract boolean	FileSystem.rename(Path src, Path dst)	Renames the file/directory src to dst.
boolean	LimitedConnectionsFileSystem.rename(Path src, Path dst)
boolean	SafetyNetWrapperFileSystem.rename(Path src, Path dst)

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

Constructor	Description
FileInputSplit(int num, Path file, long start, long length, String[] hosts)	Constructs a split with host information.
OutputStreamAndPath(FSDataOutputStream stream, Path path)	Creates a OutputStreamAndPath.
Path(String parent, Path child)	Resolve a child path against a parent path.
Path(Path parent, String child)	Resolve a child path against a parent path.
Path(Path parent, Path child)	Resolve a child path against a parent path.

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

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

Modifier and Type	Method	Description
Path	LocalFileSystem.getHomeDirectory()
Path	LocalFileStatus.getPath()
Path	LocalFileSystem.getWorkingDirectory()

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

Modifier and Type	Method	Description
FSDataOutputStream	LocalFileSystem.create(Path filePath, FileSystem.WriteMode overwrite)
boolean	LocalFileSystem.delete(Path f, boolean recursive)
boolean	LocalFileSystem.exists(Path f)
FileStatus	LocalFileSystem.getFileStatus(Path f)
FileStatus[]	LocalFileSystem.listStatus(Path f)
boolean	LocalFileSystem.mkdirs(Path f)	Recursively creates the directory specified by the provided path.
FSDataInputStream	LocalFileSystem.open(Path f)
FSDataInputStream	LocalFileSystem.open(Path f, int bufferSize)
RecoverableFsDataOutputStream	LocalRecoverableWriter.open(Path filePath)
File	LocalFileSystem.pathToFile(Path path)	Converts the given Path to a File for this file system.
boolean	LocalFileSystem.rename(Path src, Path dst)

Uses of Path in org.apache.flink.util

Methods in org.apache.flink.util that return Path

Modifier and Type	Method	Description
static Path	FileUtils.absolutizePath(Path pathToAbsolutize)	Absolutize the given path if it is relative.
static Path	FileUtils.compressDirectory(Path directory, Path target)
static Path	FileUtils.expandDirectory(Path file, Path targetDirectory)

Methods in org.apache.flink.util with parameters of type Path

Modifier and Type	Method	Description
static Path	FileUtils.absolutizePath(Path pathToAbsolutize)	Absolutize the given path if it is relative.
static Path	FileUtils.compressDirectory(Path directory, Path target)
static void	FileUtils.copy(Path sourcePath, Path targetPath, boolean executable)	Copies all files from source to target and sets executable flag.
static Path	FileUtils.expandDirectory(Path file, Path targetDirectory)