diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConstantPropagateProcCtx.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConstantPropagateProcCtx.java index f30e330..d0b10c3 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConstantPropagateProcCtx.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConstantPropagateProcCtx.java @@ -20,12 +20,12 @@ import java.io.Serializable; -import java.util.ArrayList; import java.util.HashMap; +import java.util.HashSet; import java.util.Iterator; -import java.util.List; import java.util.Map; import java.util.Map.Entry; +import java.util.Set; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hive.ql.exec.ColumnInfo; @@ -53,7 +53,7 @@ .getLog(ConstantPropagateProcCtx.class); private final Map, Map> opToConstantExprs; - private final List> opToDelete; + private final Set> opToDelete; private ConstantPropagateOption constantPropagateOption = ConstantPropagateOption.FULL; public ConstantPropagateProcCtx() { @@ -63,7 +63,7 @@ public ConstantPropagateProcCtx() { public ConstantPropagateProcCtx(ConstantPropagateOption option) { opToConstantExprs = new HashMap, Map>(); - opToDelete = new ArrayList>(); + opToDelete = new HashSet>(); this.constantPropagateOption = option; } @@ -193,7 +193,7 @@ public void addOpToDelete(Operator op) { opToDelete.add(op); } - public List> getOpToDelete() { + public Set> getOpToDelete() { return opToDelete; }