svn commit: r1625436 - in /hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql: parse/spark/SparkCompilerOld.java plan/SparkWork.java

[xuefu]

Author: xuefu
Date: Tue Sep 16 23:58:03 2014
New Revision: 1625436

URL: http://svn.apache.org/r1625436
Log:
HIVE-8140: Remove obsolete code from SparkWork [Spark Branch] (Chao via Xuefu)

Removed:
    
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SparkCompilerOld.java
Modified:
    
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/plan/SparkWork.java

Modified: 
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/plan/SparkWork.java
URL: 
http://svn.apache.org/viewvc/hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/plan/SparkWork.java?rev=1625436&r1=1625435&r2=1625436&view=diff
==============================================================================
--- 
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/plan/SparkWork.java 
(original)
+++ 
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/plan/SparkWork.java 
Tue Sep 16 23:58:03 2014
@@ -239,7 +239,7 @@ public class SparkWork extends AbstractO
   /**
    * connect adds an edge between a and b. Both nodes have
    * to be added prior to calling connect.
-   * @param  
+   * @param
    */
   public void connect(BaseWork a, BaseWork b, SparkEdgeProperty edgeProp) {
     workGraph.get(a).add(b);
@@ -252,7 +252,7 @@ public class SparkWork extends AbstractO
 
   /*
    * Dependency is a class used for explain
-   */ 
+   */
   public class Dependency implements Serializable, Comparable<Dependency> {
     public BaseWork w;
     public SparkEdgeProperty prop;
@@ -261,12 +261,12 @@ public class SparkWork extends AbstractO
     public String getName() {
       return w.getName();
     }
-    
+
     @Explain(displayName = "Shuffle Type")
     public String getShuffleType() {
       return prop.getShuffleType();
     }
-    
+
     @Override
     public int compareTo(Dependency o) {
       int compare = getName().compareTo(o.getName());
@@ -295,29 +295,5 @@ public class SparkWork extends AbstractO
     }
     return result;
   }
-
-  public MapWork getMapWork() {
-    Iterator<BaseWork> it = roots.iterator();
-    if (it.hasNext())
-      return (MapWork)roots.iterator().next();
-    return null;
-  }
-
-  public void setMapWork(MapWork mapWork) {
-    roots.add(mapWork);
-  }
-
-  public void setReduceWork(ReduceWork redWork) {
-    leaves.add(redWork);
-  }
   
-  public ReduceWork getReduceWork() {
-    Iterator<BaseWork> it = leaves.iterator();
-    if (it.hasNext()) {
-      BaseWork work = leaves.iterator().next();
-      return (work instanceof ReduceWork) ? (ReduceWork)work : null;
-    }
-    return null;
-  }
-
 }