You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@vxquery.apache.org by pr...@apache.org on 2013/12/07 03:30:24 UTC
svn commit: r1548782 - in
/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util:
ExpressionToolbox.java OperatorToolbox.java
Author: prestonc
Date: Sat Dec 7 02:30:23 2013
New Revision: 1548782
URL: http://svn.apache.org/r1548782
Log:
Started building a common toolbox for rewrite rules.
Added:
incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/ExpressionToolbox.java (with props)
incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/OperatorToolbox.java (with props)
Added: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/ExpressionToolbox.java
URL: http://svn.apache.org/viewvc/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/ExpressionToolbox.java?rev=1548782&view=auto
==============================================================================
--- incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/ExpressionToolbox.java (added)
+++ incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/ExpressionToolbox.java Sat Dec 7 02:30:23 2013
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.vxquery.compiler.rewriter.rules.util;
+
+import org.apache.commons.lang3.mutable.Mutable;
+import org.apache.vxquery.compiler.algebricks.VXQueryConstantValue;
+import org.apache.vxquery.datamodel.accessors.TaggedValuePointable;
+import org.apache.vxquery.functions.BuiltinFunctions;
+import org.apache.vxquery.functions.BuiltinOperators;
+import org.apache.vxquery.functions.Function;
+
+import edu.uci.ics.hyracks.algebricks.core.algebra.base.ILogicalExpression;
+import edu.uci.ics.hyracks.algebricks.core.algebra.base.LogicalExpressionTag;
+import edu.uci.ics.hyracks.algebricks.core.algebra.base.LogicalVariable;
+import edu.uci.ics.hyracks.algebricks.core.algebra.expressions.AbstractFunctionCallExpression;
+import edu.uci.ics.hyracks.algebricks.core.algebra.expressions.ConstantExpression;
+import edu.uci.ics.hyracks.algebricks.core.algebra.expressions.VariableReferenceExpression;
+import edu.uci.ics.hyracks.algebricks.core.algebra.functions.FunctionIdentifier;
+
+public class ExpressionToolbox {
+
+ public static Mutable<ILogicalExpression> findVariableExpression(Mutable<ILogicalExpression> mutableLe, LogicalVariable lv) {
+ ILogicalExpression le = mutableLe.getValue();
+ if (le.getExpressionTag() == LogicalExpressionTag.VARIABLE) {
+ VariableReferenceExpression vre = (VariableReferenceExpression) le;
+ if (vre.getVariableReference() == lv) {
+ return mutableLe;
+ }
+ } else if (le.getExpressionTag() == LogicalExpressionTag.FUNCTION_CALL) {
+ AbstractFunctionCallExpression afce = (AbstractFunctionCallExpression) le;
+ for (Mutable<ILogicalExpression> argExp : afce.getArguments()) {
+ Mutable<ILogicalExpression> resultLe = findVariableExpression(argExp, lv);
+ if (resultLe != null) {
+ return resultLe;
+ }
+ }
+ }
+ return null;
+ }
+
+ public static Mutable<ILogicalExpression> findFunctionExpression(Mutable<ILogicalExpression> mutableLe, FunctionIdentifier fi) {
+ ILogicalExpression le = mutableLe.getValue();
+ if (le.getExpressionTag() == LogicalExpressionTag.FUNCTION_CALL) {
+ AbstractFunctionCallExpression afce = (AbstractFunctionCallExpression) le;
+ if (afce.getFunctionIdentifier().equals(fi)) {
+ return mutableLe;
+ }
+ for (Mutable<ILogicalExpression> argExp : afce.getArguments()) {
+ Mutable<ILogicalExpression> resultLe = findFunctionExpression(argExp, fi);
+ if (resultLe != null) {
+ return resultLe;
+ }
+ }
+ }
+ return null;
+ }
+
+ public static Function getBuiltIn(Mutable<ILogicalExpression> mutableLe) {
+ ILogicalExpression le = mutableLe.getValue();
+ if (le.getExpressionTag() == LogicalExpressionTag.FUNCTION_CALL) {
+ AbstractFunctionCallExpression afce = (AbstractFunctionCallExpression) le;
+ for (Function function : BuiltinFunctions.FUNCTION_COLLECTION) {
+ if (function.getFunctionIdentifier().equals(afce.getFunctionIdentifier())) {
+ return function;
+ }
+ }
+ for (Function function : BuiltinOperators.OPERATOR_COLLECTION) {
+ if (function.getFunctionIdentifier().equals(afce.getFunctionIdentifier())) {
+ return function;
+ }
+ }
+ }
+ return null;
+ }
+
+ public static void getConstantAsPointable(ConstantExpression typeExpression, TaggedValuePointable tvp) {
+ VXQueryConstantValue treatTypeConstant = (VXQueryConstantValue) typeExpression.getValue();
+ tvp.set(treatTypeConstant.getValue(), 0, treatTypeConstant.getValue().length);
+ }
+
+
+}
Propchange: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/ExpressionToolbox.java
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/OperatorToolbox.java
URL: http://svn.apache.org/viewvc/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/OperatorToolbox.java?rev=1548782&view=auto
==============================================================================
--- incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/OperatorToolbox.java (added)
+++ incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/OperatorToolbox.java Sat Dec 7 02:30:23 2013
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.vxquery.compiler.rewriter.rules.util;
+
+import java.util.List;
+import java.util.ArrayList;
+
+import org.apache.commons.lang3.mutable.Mutable;
+
+import edu.uci.ics.hyracks.algebricks.core.algebra.base.ILogicalExpression;
+import edu.uci.ics.hyracks.algebricks.core.algebra.base.ILogicalOperator;
+import edu.uci.ics.hyracks.algebricks.core.algebra.base.LogicalOperatorTag;
+import edu.uci.ics.hyracks.algebricks.core.algebra.operators.logical.AbstractAssignOperator;
+import edu.uci.ics.hyracks.algebricks.core.algebra.operators.logical.AbstractLogicalOperator;
+import edu.uci.ics.hyracks.algebricks.core.algebra.operators.logical.AbstractUnnestOperator;
+
+public class OperatorToolbox {
+
+ public static AbstractLogicalOperator findLastSubplanOperator(AbstractLogicalOperator op) {
+ AbstractLogicalOperator next;
+ while (op.getOperatorTag() != LogicalOperatorTag.NESTEDTUPLESOURCE) {
+ op = (AbstractLogicalOperator) op.getInputs().get(0).getValue();
+ next = (AbstractLogicalOperator) op.getInputs().get(0).getValue();
+ if (next.getOperatorTag() == LogicalOperatorTag.NESTEDTUPLESOURCE) {
+ break;
+ }
+ }
+ return op;
+ }
+
+ public static List<Mutable<ILogicalExpression>> getExpression(Mutable<ILogicalOperator> opRef) {
+ AbstractLogicalOperator op = (AbstractLogicalOperator) opRef.getValue();
+ List<Mutable<ILogicalExpression>> result = new ArrayList<Mutable<ILogicalExpression>>();
+ switch (op.getOperatorTag()) {
+ case AGGREGATE:
+ case ASSIGN:
+ case RUNNINGAGGREGATE:
+ AbstractAssignOperator aao = (AbstractAssignOperator) op;
+ result.addAll(aao.getExpressions());
+ break;
+ case UNNEST:
+ case UNNEST_MAP:
+ AbstractUnnestOperator auo = (AbstractUnnestOperator) op;
+ result.add(auo.getExpressionRef());
+ break;
+ case CLUSTER:
+ case DATASOURCESCAN:
+ case DISTINCT:
+ case DISTRIBUTE_RESULT:
+ case EMPTYTUPLESOURCE:
+ case EXCHANGE:
+ case EXTENSION_OPERATOR:
+ case GROUP:
+ case INDEX_INSERT_DELETE:
+ case INNERJOIN:
+ case INSERT_DELETE:
+ case LEFTOUTERJOIN:
+ case LIMIT:
+ case NESTEDTUPLESOURCE:
+ case ORDER:
+ case PARTITIONINGSPLIT:
+ case PROJECT:
+ case REPLICATE:
+ case SCRIPT:
+ case SELECT:
+ case SINK:
+ case SUBPLAN:
+ case UNIONALL:
+ case UPDATE:
+ case WRITE:
+ case WRITE_RESULT:
+ default:
+ break;
+ }
+ return result;
+ }
+
+}
Propchange: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/compiler/rewriter/rules/util/OperatorToolbox.java
------------------------------------------------------------------------------
svn:eol-style = native