You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2013/09/11 01:44:30 UTC
git commit: TEZ-428. Add index info to event meta data. (hitesh)
Updated Branches:
refs/heads/TEZ-398 ee47464dd -> 0bd0f7941
TEZ-428. Add index info to event meta data. (hitesh)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/0bd0f794
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/0bd0f794
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/0bd0f794
Branch: refs/heads/TEZ-398
Commit: 0bd0f79411485c0626b904989fa445442bb1bdf9
Parents: ee47464
Author: Hitesh Shah <hi...@apache.org>
Authored: Tue Sep 10 16:44:18 2013 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Tue Sep 10 16:44:18 2013 -0700
----------------------------------------------------------------------
.../apache/tez/engine/newapi/impl/EventMetaData.java | 15 +++++++++++++++
1 file changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/0bd0f794/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/EventMetaData.java
----------------------------------------------------------------------
diff --git a/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/EventMetaData.java b/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/EventMetaData.java
index 933b48f..3ef271f 100644
--- a/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/EventMetaData.java
+++ b/tez-engine/src/main/java/org/apache/tez/engine/newapi/impl/EventMetaData.java
@@ -54,6 +54,11 @@ public class EventMetaData implements Writable {
private String edgeVertexName;
/**
+ * i'th physical input/output that this event maps to.
+ */
+ private int index;
+
+ /**
* Task Attempt ID
*/
private TezTaskAttemptID taskAttemptID;
@@ -102,6 +107,7 @@ public class EventMetaData implements Writable {
out.writeBoolean(false);
}
taskAttemptID.write(out);
+ out.writeInt(index);
}
@Override
@@ -115,6 +121,15 @@ public class EventMetaData implements Writable {
}
taskAttemptID = new TezTaskAttemptID();
taskAttemptID.readFields(in);
+ index = in.readInt();
+ }
+
+ public int getIndex() {
+ return index;
+ }
+
+ public void setIndex(int index) {
+ this.index = index;
}
}