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;
