diff --git a/ql/src/java/org/apache/hadoop/hive/ql/QueryProperties.java b/ql/src/java/org/apache/hadoop/hive/ql/QueryProperties.java index 1ba5654..a73256f 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/QueryProperties.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/QueryProperties.java @@ -143,4 +143,22 @@ public boolean isHasMapGroupBy() { public void setHasMapGroupBy(boolean hasMapGroupBy) { this.hasMapGroupBy = hasMapGroupBy; } + + public void clear() { + hasJoin = false; + hasGroupBy = false; + hasOrderBy = false; + hasSortBy = false; + hasJoinFollowedByGroupBy = false; + hasPTF = false; + hasWindowing = false; + + // does the query have a using clause + usesScript = false; + + hasDistributeBy = false; + hasClusterBy = false; + mapJoinRemoved = false; + hasMapGroupBy = false; + } } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java index 73603ab..2b91ee6 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java @@ -321,6 +321,28 @@ protected void reset() { groupOpToInputTables.clear(); prunedPartitions.clear(); aliasToCTEs.clear(); + topToTable.clear(); + opToPartPruner.clear(); + opToPartList.clear(); + opToPartToSkewedPruner.clear(); + opToSamplePruner.clear(); + nameToSplitSample.clear(); + fsopToTable.clear(); + resultSchema = null; + createVwDesc = null; + viewsExpanded = null; + viewSelect = null; + ctesExpanded = null; + noscan = false; + partialscan = false; + globalLimitCtx.disableOpt(); + viewAliasToInput.clear(); + reduceSinkOperatorsAddedByEnforceBucketingSorting.clear(); + topToTableProps.clear(); + listMapJoinOpsNoReducer.clear(); + unparseTranslator.clear(); + queryProperties.clear(); + outputs.clear(); } public void initParseCtx(ParseContext pctx) { diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/UnparseTranslator.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/UnparseTranslator.java index c69f747..9ad6714 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/UnparseTranslator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/UnparseTranslator.java @@ -262,4 +262,10 @@ public String toString() { ASTNode targetNode; ASTNode sourceNode; } + + public void clear() { + translations.clear(); + copyTranslations.clear(); + enabled = false; + } }