You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2013/09/10 03:51:39 UTC
git commit: TEZ-425. Create DataMovementEvent and
InputInformationEvent user payloads for shuffle (part of TEZ-398). (sseth)
Updated Branches:
refs/heads/TEZ-398 40e526df1 -> 4baeabc9a
TEZ-425. Create DataMovementEvent and InputInformationEvent user
payloads for shuffle (part of TEZ-398). (sseth)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/4baeabc9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/4baeabc9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/4baeabc9
Branch: refs/heads/TEZ-398
Commit: 4baeabc9a3f5317c49dcca256454ac7792337ecf
Parents: 40e526d
Author: Siddharth Seth <ss...@apache.org>
Authored: Mon Sep 9 18:51:14 2013 -0700
Committer: Siddharth Seth <ss...@apache.org>
Committed: Mon Sep 9 18:51:14 2013 -0700
----------------------------------------------------------------------
tez-engine/pom.xml | 1 +
tez-engine/src/main/proto/ShufflePayloads.proto | 32 ++++++++++++++++++++
2 files changed, 33 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/4baeabc9/tez-engine/pom.xml
----------------------------------------------------------------------
diff --git a/tez-engine/pom.xml b/tez-engine/pom.xml
index ecfdc04..82eb48a 100644
--- a/tez-engine/pom.xml
+++ b/tez-engine/pom.xml
@@ -83,6 +83,7 @@
<directory>${basedir}/src/main/proto</directory>
<includes>
<include>Events.proto</include>
+ <include>ShufflePayloads.proto</include>
</includes>
</source>
<output>${project.build.directory}/generated-sources/java</output>
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/4baeabc9/tez-engine/src/main/proto/ShufflePayloads.proto
----------------------------------------------------------------------
diff --git a/tez-engine/src/main/proto/ShufflePayloads.proto b/tez-engine/src/main/proto/ShufflePayloads.proto
new file mode 100644
index 0000000..b16b4da
--- /dev/null
+++ b/tez-engine/src/main/proto/ShufflePayloads.proto
@@ -0,0 +1,32 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+option java_package = "org.apache.tez.engine.common.shuffle.newimpl";
+option java_outer_classname = "ShuffleUserPayloads";
+option java_generate_equals_and_hash = true;
+
+message DataMovementEventPayloadProto {
+ optional string host = 1;
+ optional int32 port = 2;
+ optional string path_component = 3;
+ optional int32 run_duration = 4;
+}
+
+message InputInformationEventPayloadProto {
+ optional int32 partition_range = 1;
+}