Changeset 28 for sample/hadoop-0.16/tw/org/nchc/util/SequenceFileProcessor.java

Timestamp:

Jul 3, 2008, 5:40:27 PM (16 years ago)

Author:

waue

Message:

resolve 0.17 ->0.16 problem . all? not sure ! XD

File:

• sample/hadoop-0.16/tw/org/nchc/util/SequenceFileProcessor.java (modified) (3 diffs)

sample/hadoop-0.16/tw/org/nchc/util/SequenceFileProcessor.java

@@ -19 +19 @@
 import java.io.IOException;
 
+import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
@@ -118 +119 @@
 
   private void run() throws IOException {
-    if (!FileSystem.get(conf).isFile(mPath)) {
-      for (Path p : FileSystem.get(conf).listPaths(new Path[] { mPath })) {
+    FileSystem fs = FileSystem.get(conf);
+    if (!fs.isFile(mPath)) {
+            for (Path p : listPaths(fs,mPath)) {
         // System.out.println("Applying to " + p);
         applyToFile(p);
@@ -128 +130 @@
 
   }
-
+  static public Path[] listPaths(FileSystem fsm,Path path) throws IOException
+  {
+    FileStatus[] fss = fsm.listStatus(path);
+    int length = fss.length;
+    Path[] pi = new Path[length];
+    for (int i=0 ; i< length; i++)
+    {
+      pi[i] = fss[i].getPath();
+    }
+    return pi;
+  }
   @SuppressWarnings("unchecked")
   private void applyToFile(Path path) throws IOException {