org.apache.hadoop.fs.FileStatus#toString ( )源码实例Demo

下面列出了org.apache.hadoop.fs.FileStatus#toString ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hadoop 文件： TestSwiftFileSystemPartitionedUploads.java

private FileStatus validatePathLen(Path path, int len) throws IOException {
  //verify that the length is what was written in a direct status check
  final Path qualifiedPath = path.makeQualified(fs);
  FileStatus[] parentDirListing = fs.listStatus(qualifiedPath.getParent());
  StringBuilder listing = lsToString(parentDirListing);
  String parentDirLS = listing.toString();
  FileStatus status = fs.getFileStatus(qualifiedPath);
  assertEquals("Length of written file " + qualifiedPath
               + " from status check " + status
               + " in dir " + listing,
               len,
               status.getLen());
  String fileInfo = qualifiedPath + "  " + status;
  assertFalse("File claims to be a directory " + fileInfo,
              status.isDir());

  FileStatus listedFileStat = resolveChild(parentDirListing, qualifiedPath);
  assertNotNull("Did not find " + path + " in " + parentDirLS,
                listedFileStat);
  //file is in the parent dir. Now validate it's stats
  assertEquals("Wrong len for " + path + " in listing " + parentDirLS,
               len,
               listedFileStat.getLen());
  listedFileStat.toString();
  return status;
}

源代码2 项目： big-c 文件： TestSwiftFileSystemPartitionedUploads.java

private FileStatus validatePathLen(Path path, int len) throws IOException {
  //verify that the length is what was written in a direct status check
  final Path qualifiedPath = path.makeQualified(fs);
  FileStatus[] parentDirListing = fs.listStatus(qualifiedPath.getParent());
  StringBuilder listing = lsToString(parentDirListing);
  String parentDirLS = listing.toString();
  FileStatus status = fs.getFileStatus(qualifiedPath);
  assertEquals("Length of written file " + qualifiedPath
               + " from status check " + status
               + " in dir " + listing,
               len,
               status.getLen());
  String fileInfo = qualifiedPath + "  " + status;
  assertFalse("File claims to be a directory " + fileInfo,
              status.isDir());

  FileStatus listedFileStat = resolveChild(parentDirListing, qualifiedPath);
  assertNotNull("Did not find " + path + " in " + parentDirLS,
                listedFileStat);
  //file is in the parent dir. Now validate it's stats
  assertEquals("Wrong len for " + path + " in listing " + parentDirLS,
               len,
               listedFileStat.getLen());
  listedFileStat.toString();
  return status;
}

源代码3 项目： sahara-extra 文件： TestSwiftFileSystemPartitionedUploads.java

private FileStatus validatePathLen(Path path, int len) throws IOException {
  //verify that the length is what was written in a direct status check
  final Path qualifiedPath = path.makeQualified(fs);
  FileStatus[] parentDirListing = fs.listStatus(qualifiedPath.getParent());
  StringBuilder listing = lsToString(parentDirListing);
  String parentDirLS = listing.toString();
  FileStatus status = fs.getFileStatus(qualifiedPath);
  assertEquals("Length of written file " + qualifiedPath
               + " from status check " + status
               + " in dir " + listing,
               len,
               status.getLen());
  String fileInfo = qualifiedPath + "  " + status;
  assertFalse("File claims to be a directory " + fileInfo,
              status.isDir());

  FileStatus listedFileStat = resolveChild(parentDirListing, qualifiedPath);
  assertNotNull("Did not find " + path + " in " + parentDirLS,
                listedFileStat);
  //file is in the parent dir. Now validate it's stats
  assertEquals("Wrong len for " + path + " in listing " + parentDirLS,
               len,
               listedFileStat.getLen());
  listedFileStat.toString();
  return status;
}

源代码4 项目： hadoop 文件： ContractTestUtils.java

/**
 * Read a file, verify its length and contents match the expected array
 * @param fs filesystem
 * @param path path to file
 * @param original original dataset
 * @throws IOException IO Problems
 */
public static void verifyFileContents(FileSystem fs,
                                      Path path,
                                      byte[] original) throws IOException {
  FileStatus stat = fs.getFileStatus(path);
  String statText = stat.toString();
  assertTrue("not a file " + statText, stat.isFile());
  assertEquals("wrong length " + statText, original.length, stat.getLen());
  byte[] bytes = readDataset(fs, path, original.length);
  compareByteArrays(original,bytes,original.length);
}

源代码5 项目： big-c 文件： ContractTestUtils.java

/**
 * Read a file, verify its length and contents match the expected array
 * @param fs filesystem
 * @param path path to file
 * @param original original dataset
 * @throws IOException IO Problems
 */
public static void verifyFileContents(FileSystem fs,
                                      Path path,
                                      byte[] original) throws IOException {
  FileStatus stat = fs.getFileStatus(path);
  String statText = stat.toString();
  assertTrue("not a file " + statText, stat.isFile());
  assertEquals("wrong length " + statText, original.length, stat.getLen());
  byte[] bytes = readDataset(fs, path, original.length);
  compareByteArrays(original,bytes,original.length);
}

方法所在类

org.apache.hadoop.fs.FileStatus