Changeset 25 for sample/hadoop-0.16/tw/org/nchc/util

Timestamp:

Jul 3, 2008, 4:45:54 PM (16 years ago)

Author:

waue

Message:

downgrade from 0.17 to 0.16
test for work -> not yet

Location:

sample/hadoop-0.16/tw/org/nchc/util

Files:

• SequenceFileProcessor.class (modified) (previous)
• SequenceFileProcessor.java (modified) (4 diffs)

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

@@ -1 @@
-/**
- * Program: BuildHTable.java
- * Editor: Waue Chen 
- * From :  NCHC. Taiwn
- * Last Update Date: 07/02/2008
- * Upgrade to 0.17
- * Re-code from : Cloud9: A MapReduce Library for Hadoop
+/*
+ * Cloud9: A MapReduce Library for Hadoop
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you
+ * may not use this file except in compliance with the License. You may
+ * obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0 
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied. See the License for the specific language governing
+ * permissions and limitations under the License.
  */
-
 
 package tw.org.nchc.util;
@@ -13 +19 @@
 import java.io.IOException;
 
-import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
@@ -22 +27 @@
 
 /**
- * Upgrade from hadoop 0.16 to 0.17 
  * <p>
  * Harness for processing one or more {@link SequenceFile}s within a single
@@ -115 +119 @@
   private void run() throws IOException {
     if (!FileSystem.get(conf).isFile(mPath)) {
-      Path[] pa = new Path[] { mPath };
-      Path p;
-      // hadoop 0.17 -> listStatus();
-      FileStatus[] fi = FileSystem.get(conf).listStatus(pa);
-      for (int i =0 ; i<fi.length ; i++) {
-        p = fi[i].getPath();
+      for (Path p : FileSystem.get(conf).listPaths(new Path[] { mPath })) {
         // System.out.println("Applying to " + p);
         applyToFile(p);