-
Notifications
You must be signed in to change notification settings - Fork 425
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
TEZ-4227 Introduce convenient methods in TezID subclasses #166
Conversation
This comment has been minimized.
This comment has been minimized.
This comment was marked as outdated.
This comment was marked as outdated.
@@ -154,8 +154,7 @@ private void processDownstreamVertices(Vertex vertex) { | |||
List<Vertex> newlyScheduledVertices = Lists.newLinkedList(); | |||
Map<Vertex, Edge> outputVertexEdgeMap = vertex.getOutputVertices(); | |||
for (Vertex destVertex : outputVertexEdgeMap.keySet()) { | |||
if (vertexAlreadyScheduled(destVertex)) { // Nothing to do if already scheduled. | |||
} else { | |||
if (!vertexAlreadyScheduled(destVertex)) { // Nothing to do if already scheduled. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you can delete the comment "Nothing to do" from here as it corresponds to the deleted branch
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
import org.apache.hadoop.yarn.api.records.ApplicationId; | ||
|
||
public interface DAGIDAware { | ||
TezDAGID getDAGId(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
even if it looks strange (too many capitals), this might be changed to
getDAGID();
to stay consistent with others, so it should suggest that a TezID Object is returned here which is "ID", not an integer, which is id
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
This comment was marked as outdated.
This comment was marked as outdated.
This comment was marked as outdated.
This comment was marked as outdated.
Change-Id: I6cabfa75e9b6b62e41ba8c2cc5e3d2d1a8a49102
This comment was marked as outdated.
This comment was marked as outdated.
🎊 +1 overall
This message was automatically generated. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1 after addressing comments, this patch looks good to me, approving
I like the introduction of *IDAware interfaces, also having a consistent letter case: "ID" for TezID objects, "Id" for the integer inside
as the patch touches lots of code, let me give another 24-48h for others to tell their opinion (cc: @rbalamohan, @jteagles)
@ghanko: could you please check how the patch applies to branch-0.9? I'm pretty sure it has a bunch of conflicts, but I'm hoping all of them are obvious...if we could have the patch on branch-0.9, it helps to reduce the divergence between master/branch-0.9...only if it doesn't take too much time
Change-Id: I6cabfa75e9b6b62e41ba8c2cc5e3d2d1a8a49102