You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by bi...@apache.org on 2014/01/22 00:29:45 UTC
git commit: Addendum to TEZ-650.
MRHelpers.createMRInputPayloadWithGrouping() methods should not take an
MRSplitsProto argument (bikas)
Updated Branches:
refs/heads/master 42fb13a61 -> 1600b5653
Addendum to TEZ-650. MRHelpers.createMRInputPayloadWithGrouping() methods should not take an MRSplitsProto argument (bikas)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/1600b565
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/1600b565
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/1600b565
Branch: refs/heads/master
Commit: 1600b5653e67f57c14a62bfe8f8fa66c36aa596a
Parents: 42fb13a
Author: Bikas Saha <bi...@apache.org>
Authored: Tue Jan 21 15:29:13 2014 -0800
Committer: Bikas Saha <bi...@apache.org>
Committed: Tue Jan 21 15:29:13 2014 -0800
----------------------------------------------------------------------
.../org/apache/tez/mapreduce/hadoop/MRHelpers.java | 16 ----------------
1 file changed, 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/1600b565/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRHelpers.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRHelpers.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRHelpers.java
index 7f7baf5..eaa597a 100644
--- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRHelpers.java
+++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MRHelpers.java
@@ -729,22 +729,6 @@ public class MRHelpers {
null, inputFormatName);
}
- /**
- * Called to specify that grouping of input splits be performed by Tez
- * The conf should have the input format class configuration
- * set to the TezGroupedSplitsInputFormat. The real input format class name
- * should be passed as an argument to this method.
- */
- public static byte[] createMRInputPayloadWithGrouping(Configuration conf,
- MRSplitsProto mrSplitsProto, String inputFormatName) throws IOException {
- Preconditions
- .checkArgument(conf != null, "Configuration must be specified");
- Preconditions.checkArgument(inputFormatName != null,
- "InputFormat must be specified");
- return createMRInputPayload(createByteStringFromConf(conf),
- mrSplitsProto, inputFormatName);
- }
-
private static byte[] createMRInputPayload(ByteString bytes,
MRSplitsProto mrSplitsProto, String inputFormatName) throws IOException {
MRInputUserPayloadProto.Builder userPayloadBuilder = MRInputUserPayloadProto