public class HdfsUtils extends Object
Constructor and Description |
---|
HdfsUtils() |
Modifier and Type | Method and Description |
---|---|
static long |
createTestFileId(String pathStr,
org.apache.hadoop.fs.FileStatus fs,
boolean doLog,
String fsName) |
static Object |
getFileId(org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
boolean allowSynthetic,
boolean checkDefaultFs) |
static org.apache.hadoop.fs.Path |
getFileIdPath(org.apache.hadoop.fs.FileSystem fileSystem,
org.apache.hadoop.fs.Path path,
long fileId) |
static boolean |
isDefaultFs(org.apache.hadoop.hdfs.DistributedFileSystem fs) |
static List<org.apache.hadoop.fs.FileStatus> |
listLocatedStatus(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.PathFilter filter) |
public static Object getFileId(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.fs.Path path, boolean allowSynthetic, boolean checkDefaultFs) throws IOException
IOException
public static long createTestFileId(String pathStr, org.apache.hadoop.fs.FileStatus fs, boolean doLog, String fsName)
public static List<org.apache.hadoop.fs.FileStatus> listLocatedStatus(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.PathFilter filter) throws IOException
IOException
public static org.apache.hadoop.fs.Path getFileIdPath(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.fs.Path path, long fileId)
public static boolean isDefaultFs(org.apache.hadoop.hdfs.DistributedFileSystem fs)
Copyright © 2022 The Apache Software Foundation. All rights reserved.