org.apache.hadoop.hive.ql.plan.OperatorDesc



API Populatity

2 Client projects

Project: org.apache

Project apache/hive in file ...rg.apache.hadoop.hive.ql.exec.GroupByOperator.java (2012-08-29)
@@ -42,6 +42,7 @@
 import org.apache.hadoop.hive.ql.plan.ExprNodeColumnDesc;
 import org.apache.hadoop.hive.ql.plan.ExprNodeDesc;
 import org.apache.hadoop.hive.ql.plan.GroupByDesc;
+import org.apache.hadoop.hive.ql.plan.OperatorDesc;
 import org.apache.hadoop.hive.ql.plan.api.OperatorType;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator;
 import org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AggregationBuffer;
@@ -1057,7 +1058,7 @@ public void closeOp(boolean abort) throws HiveException {
 
   // Group by contains the columns needed - no need to aggregate from children
   public List<String> genColLists(
-      HashMap<Operator<? extends Serializable>, OpParseContext> opParseCtx) {
+      HashMap<Operator<? extends OperatorDesc>, OpParseContext> opParseCtx) {
     List<String> colLists = new ArrayList<String>();
     ArrayList<ExprNodeDesc> keys = conf.getKeys();
     for (ExprNodeDesc key : keys) {
Project apache/hive in file ...ava.org.apache.hadoop.hive.ql.exec.MapRedTask.java (2012-08-29)
@@ -39,6 +39,7 @@
 import org.apache.hadoop.hive.ql.exec.Utilities.StreamPrinter;
 import org.apache.hadoop.hive.ql.metadata.HiveException;
 import org.apache.hadoop.hive.ql.plan.MapredWork;
+import org.apache.hadoop.hive.ql.plan.OperatorDesc;
 import org.apache.hadoop.hive.ql.session.SessionState;
 import org.apache.hadoop.hive.shims.ShimLoader;
 import org.apache.hadoop.mapred.JobConf;
@@ -548,7 +549,7 @@ public static String isEligibleForLocalMode(HiveConf conf,
   }
 
   @Override
-  public Operator<? extends Serializable> getReducer() {
+  public Operator<? extends OperatorDesc> getReducer() {
     return getWork().getReducer();
   }
 }
Project apache/hive in file ...g.apache.hadoop.hive.ql.exec.TerminalOperator.java (2012-08-29)
@@ -20,10 +20,12 @@
 
 import java.io.Serializable;
 
+import org.apache.hadoop.hive.ql.plan.OperatorDesc;
+
 /**
  * Terminal Operator Base Class.
  **/
-public abstract class TerminalOperator<T extends Serializable> extends
+public abstract class TerminalOperator<T extends OperatorDesc> extends
     Operator<T> implements Serializable {
   private static final long serialVersionUID = 1L;