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;