tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject tez git commit: TEZ-3151. Expose DAG credentials to plugins. Contributed by Sergey Shelukhin.
Date Tue, 01 Mar 2016 00:34:24 GMT
Repository: tez
Updated Branches:
  refs/heads/master e9e9db1b6 -> ac0fd8bb3


TEZ-3151. Expose DAG credentials to plugins. Contributed by Sergey Shelukhin.


Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/ac0fd8bb
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/ac0fd8bb
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/ac0fd8bb

Branch: refs/heads/master
Commit: ac0fd8bb34ebb345d018b73e5ffebbab8343b2f9
Parents: e9e9db1
Author: Siddharth Seth <sseth@apache.org>
Authored: Mon Feb 29 16:34:00 2016 -0800
Committer: Siddharth Seth <sseth@apache.org>
Committed: Mon Feb 29 16:34:00 2016 -0800

----------------------------------------------------------------------
 CHANGES.txt                                                  | 1 +
 .../main/java/org/apache/tez/serviceplugins/api/DagInfo.java | 8 ++++++++
 tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java    | 2 --
 .../java/org/apache/tez/dag/helpers/DagInfoImplForTest.java  | 6 ++++++
 4 files changed, 15 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 8084a59..47913ab 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -7,6 +7,7 @@ INCOMPATIBLE CHANGES
   TEZ-3029. Add an onError method to service plugin contexts.
 
 ALL CHANGES:
+  TEZ-3151. Expose DAG credentials to plugins.
   TEZ-3149. Tez-tools: Add username in DagInfo.
   TEZ-2988. DAGAppMaster::shutdownTezAM should return with a no-op if it has been invoked
earlier.
   TEZ-3147. Intermediate mem-to-mem: Fix early exit when only one segment can fit into memory

http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java
----------------------------------------------------------------------
diff --git a/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java b/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java
index ef73343..4a8b9fa 100644
--- a/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java
+++ b/tez-api/src/main/java/org/apache/tez/serviceplugins/api/DagInfo.java
@@ -14,6 +14,8 @@
 
 package org.apache.tez.serviceplugins.api;
 
+import org.apache.hadoop.security.Credentials;
+
 public interface DagInfo {
 
   /**
@@ -27,4 +29,10 @@ public interface DagInfo {
    * @return the name of the dag
    */
   String getName();
+
+  /**
+   * Get credentials for the dag.
+   * @return the credentials for the dag.
+   */
+  Credentials getCredentials();
 }

http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java
index dd96ab2..6c8e8f9 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java
@@ -86,8 +86,6 @@ public interface DAG extends DagInfo {
 
   boolean isComplete();
 
-  Credentials getCredentials();
-  
   UserGroupInformation getDagUGI();
 
   ACLManager getACLManager();

http://git-wip-us.apache.org/repos/asf/tez/blob/ac0fd8bb/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java b/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java
index f92513f..b0eeaef 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/helpers/DagInfoImplForTest.java
@@ -14,6 +14,7 @@
 
 package org.apache.tez.dag.helpers;
 
+import org.apache.hadoop.security.Credentials;
 import org.apache.tez.serviceplugins.api.DagInfo;
 
 public class DagInfoImplForTest implements DagInfo {
@@ -35,4 +36,9 @@ public class DagInfoImplForTest implements DagInfo {
   public String getName() {
     return name;
   }
+
+  @Override
+  public Credentials getCredentials() {
+    return null;
+  }
 }


Mime
View raw message