public final class FileUtils
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
escapePathName(java.lang.String path) |
static java.lang.String |
escapePathName(java.lang.String path,
java.lang.String defaultPath)
Escapes a path name.
|
static void |
listStatusRecursively(FileSystem fs,
FileStatus fileStatus,
java.util.List<FileStatus> results)
Recursively lists status for all files starting from a particular directory (or individual file
as base case).
|
static java.lang.String |
makeDefaultListBucketingDirName(java.util.List<java.lang.String> skewedCols,
java.lang.String name)
default directory will have the same depth as number of skewed columns
this will make future operation easy like DML merge, concatenate merge
|
static java.lang.String |
makeListBucketingDirName(java.util.List<java.lang.String> lbCols,
java.util.List<java.lang.String> vals)
Makes a valid list bucketing directory name.
|
static java.lang.String |
makePartName(java.util.List<java.lang.String> partCols,
java.util.List<java.lang.String> vals) |
static java.lang.String |
makePartName(java.util.List<java.lang.String> partCols,
java.util.List<java.lang.String> vals,
java.lang.String defaultStr)
Makes a valid partition name.
|
static Path |
makeQualified(Path path,
Configuration conf)
Variant of Path.makeQualified that qualifies the input path against the default file system
indicated by the configuration
This does not require a FileSystem handle in most cases - only requires the Filesystem URI.
|
static java.lang.String |
unescapePathName(java.lang.String path) |
public static Path makeQualified(Path path, Configuration conf) throws java.io.IOException
path
- path to be fully qualifiedconf
- Configuration filejava.io.IOException
public static java.lang.String makePartName(java.util.List<java.lang.String> partCols, java.util.List<java.lang.String> vals)
public static java.lang.String makePartName(java.util.List<java.lang.String> partCols, java.util.List<java.lang.String> vals, java.lang.String defaultStr)
partCols
- The partition keys' namesvals
- The partition valuesdefaultStr
- The default name given to a partition value if the respective value is empty or null.public static java.lang.String makeDefaultListBucketingDirName(java.util.List<java.lang.String> skewedCols, java.lang.String name)
skewedCols
- name
- public static java.lang.String makeListBucketingDirName(java.util.List<java.lang.String> lbCols, java.util.List<java.lang.String> vals)
lbCols
- The skewed keys' namesvals
- The skewed valuespublic static java.lang.String escapePathName(java.lang.String path)
public static java.lang.String escapePathName(java.lang.String path, java.lang.String defaultPath)
path
- The path to escape.defaultPath
- The default name for the path, if the given path is empty or null.public static java.lang.String unescapePathName(java.lang.String path)
public static void listStatusRecursively(FileSystem fs, FileStatus fileStatus, java.util.List<FileStatus> results) throws java.io.IOException
fs
- file systemfileStatus
- starting point in file systemresults
- receives enumeration of all files foundjava.io.IOException
Copyright © 2012 The Apache Software Foundation