You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by jw...@apache.org on 2013/01/10 22:22:54 UTC

[1/2] CRUNCH-127: Support writing multiple HBaseTargets in a single job, which required renaming InputBundles to FormatBundles, creating a CrunchOutputs to go along with CrunchInputs and deleting the old MultipleOutputs code, and creating our own TableOu

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/522a691c/crunch/src/main/java/org/apache/crunch/io/text/TextFileTableSource.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/io/text/TextFileTableSource.java b/crunch/src/main/java/org/apache/crunch/io/text/TextFileTableSource.java
index e3c4cd5..94fc5fd 100644
--- a/crunch/src/main/java/org/apache/crunch/io/text/TextFileTableSource.java
+++ b/crunch/src/main/java/org/apache/crunch/io/text/TextFileTableSource.java
@@ -21,7 +21,7 @@ import java.io.IOException;
 
 import org.apache.crunch.Pair;
 import org.apache.crunch.io.CompositePathIterable;
-import org.apache.crunch.io.InputBundle;
+import org.apache.crunch.io.FormatBundle;
 import org.apache.crunch.io.ReadableSource;
 import org.apache.crunch.io.impl.FileTableSourceImpl;
 import org.apache.crunch.types.PTableType;
@@ -42,8 +42,8 @@ public class TextFileTableSource<K, V> extends FileTableSourceImpl<K, V>
   private static final String OLD_KV_SEP = "key.value.separator.in.input.line";
   private static final String NEW_KV_SEP = "mapreduce.input.keyvaluelinerecordreader.key.value.separator";
   
-  private static InputBundle getBundle(String sep) {
-    InputBundle bundle = new InputBundle(KeyValueTextInputFormat.class);
+  private static FormatBundle getBundle(String sep) {
+    FormatBundle bundle = FormatBundle.forInput(KeyValueTextInputFormat.class);
     bundle.set(OLD_KV_SEP, sep);
     bundle.set(NEW_KV_SEP, sep);
     return bundle;