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 2012/08/30 23:34:19 UTC
svn commit: r1379164 -
/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/node/FnNumberScalarEvaluatorFactory.java
Author: prestonc
Date: Thu Aug 30 21:34:19 2012
New Revision: 1379164
URL: http://svn.apache.org/viewvc?rev=1379164&view=rev
Log:
Added fn:number.
Added:
incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/node/FnNumberScalarEvaluatorFactory.java (with props)
Added: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/node/FnNumberScalarEvaluatorFactory.java
URL: http://svn.apache.org/viewvc/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/node/FnNumberScalarEvaluatorFactory.java?rev=1379164&view=auto
==============================================================================
--- incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/node/FnNumberScalarEvaluatorFactory.java (added)
+++ incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/node/FnNumberScalarEvaluatorFactory.java Thu Aug 30 21:34:19 2012
@@ -0,0 +1,137 @@
+package org.apache.vxquery.runtime.functions.node;
+
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.vxquery.datamodel.accessors.TaggedValuePointable;
+import org.apache.vxquery.datamodel.accessors.atomic.XSDecimalPointable;
+import org.apache.vxquery.datamodel.values.ValueTag;
+import org.apache.vxquery.exceptions.ErrorCode;
+import org.apache.vxquery.exceptions.SystemException;
+import org.apache.vxquery.runtime.functions.base.AbstractTaggedValueArgumentScalarEvaluator;
+import org.apache.vxquery.runtime.functions.base.AbstractTaggedValueArgumentScalarEvaluatorFactory;
+import org.apache.vxquery.runtime.functions.cast.CastToDoubleOperation;
+
+import edu.uci.ics.hyracks.algebricks.common.exceptions.AlgebricksException;
+import edu.uci.ics.hyracks.algebricks.runtime.base.IScalarEvaluator;
+import edu.uci.ics.hyracks.algebricks.runtime.base.IScalarEvaluatorFactory;
+import edu.uci.ics.hyracks.api.context.IHyracksTaskContext;
+import edu.uci.ics.hyracks.data.std.api.IPointable;
+import edu.uci.ics.hyracks.data.std.primitive.BooleanPointable;
+import edu.uci.ics.hyracks.data.std.primitive.BytePointable;
+import edu.uci.ics.hyracks.data.std.primitive.DoublePointable;
+import edu.uci.ics.hyracks.data.std.primitive.FloatPointable;
+import edu.uci.ics.hyracks.data.std.primitive.IntegerPointable;
+import edu.uci.ics.hyracks.data.std.primitive.LongPointable;
+import edu.uci.ics.hyracks.data.std.primitive.ShortPointable;
+import edu.uci.ics.hyracks.data.std.primitive.UTF8StringPointable;
+import edu.uci.ics.hyracks.data.std.util.ArrayBackedValueStorage;
+
+public class FnNumberScalarEvaluatorFactory extends AbstractTaggedValueArgumentScalarEvaluatorFactory {
+ private static final long serialVersionUID = 1L;
+
+ public FnNumberScalarEvaluatorFactory(IScalarEvaluatorFactory[] args) {
+ super(args);
+ }
+
+ @Override
+ protected IScalarEvaluator createEvaluator(IHyracksTaskContext ctx, IScalarEvaluator[] args)
+ throws AlgebricksException {
+ final ArrayBackedValueStorage abvs = new ArrayBackedValueStorage();
+ final DataOutput dOut = abvs.getDataOutput();
+ final CastToDoubleOperation castToDouble = new CastToDoubleOperation();
+ final TypedPointables tp = new TypedPointables();
+
+ return new AbstractTaggedValueArgumentScalarEvaluator(args) {
+ @Override
+ protected void evaluate(TaggedValuePointable[] args, IPointable result) throws SystemException {
+ TaggedValuePointable tvp1 = args[0];
+ try {
+ abvs.reset();
+ switch (tvp1.getTag()) {
+ case ValueTag.XS_STRING_TAG:
+ tvp1.getValue(tp.utf8sp);
+ castToDouble.convertString(tp.utf8sp, dOut);
+ break;
+ case ValueTag.XS_UNTYPED_ATOMIC_TAG:
+ tvp1.getValue(tp.utf8sp);
+ castToDouble.convertUntypedAtomic(tp.utf8sp, dOut);
+ break;
+ case ValueTag.XS_BOOLEAN_TAG:
+ tvp1.getValue(tp.boolp);
+ castToDouble.convertBoolean(tp.boolp, dOut);
+ break;
+// case ValueTag.XS_YEAR_MONTH_DURATION_TAG:
+ case ValueTag.XS_INTEGER_TAG:
+ case ValueTag.XS_NON_POSITIVE_INTEGER_TAG:
+ case ValueTag.XS_NEGATIVE_INTEGER_TAG:
+ case ValueTag.XS_LONG_TAG:
+ case ValueTag.XS_NON_NEGATIVE_INTEGER_TAG:
+ case ValueTag.XS_UNSIGNED_LONG_TAG:
+ case ValueTag.XS_POSITIVE_INTEGER_TAG:
+ case ValueTag.XS_UNSIGNED_INT_TAG:
+ tvp1.getValue(tp.longp);
+ castToDouble.convertInteger(tp.longp, dOut);
+ break;
+// case ValueTag.XS_DAY_TIME_DURATION_TAG:
+ case ValueTag.XS_INT_TAG:
+ case ValueTag.XS_UNSIGNED_SHORT_TAG:
+ tvp1.getValue(tp.intp);
+ castToDouble.convertInt(tp.intp, dOut);
+ break;
+ case ValueTag.XS_DECIMAL_TAG:
+ tvp1.getValue(tp.decp);
+ castToDouble.convertDecimal(tp.decp, dOut);
+ break;
+ case ValueTag.XS_DOUBLE_TAG:
+ tvp1.getValue(tp.doublep);
+ castToDouble.convertDouble(tp.doublep, dOut);
+ break;
+ case ValueTag.XS_FLOAT_TAG:
+ tvp1.getValue(tp.floatp);
+ castToDouble.convertFloat(tp.floatp, dOut);
+ break;
+ case ValueTag.XS_SHORT_TAG:
+ case ValueTag.XS_UNSIGNED_BYTE_TAG:
+ tvp1.getValue(tp.shortp);
+ castToDouble.convertShort(tp.shortp, dOut);
+ break;
+ case ValueTag.XS_BYTE_TAG:
+ tvp1.getValue(tp.bytep);
+ castToDouble.convertByte(tp.bytep, dOut);
+ break;
+ default:
+ dOut.write(ValueTag.XS_DOUBLE_TAG);
+ dOut.writeDouble(Double.NaN);
+ }
+
+ result.set(abvs);
+ } catch (SystemException e) {
+ try {
+ abvs.reset();
+ dOut.write(ValueTag.XS_DOUBLE_TAG);
+ dOut.writeDouble(Double.NaN);
+ result.set(abvs);
+ } catch (IOException e1) {
+ throw new SystemException(ErrorCode.SYSE0001, e);
+ }
+ } catch (IOException e) {
+ throw new SystemException(ErrorCode.SYSE0001, e);
+ }
+ }
+
+ };
+ }
+
+ private static class TypedPointables {
+ BooleanPointable boolp = (BooleanPointable) BooleanPointable.FACTORY.createPointable();
+ BytePointable bytep = (BytePointable) BytePointable.FACTORY.createPointable();
+ DoublePointable doublep = (DoublePointable) DoublePointable.FACTORY.createPointable();
+ FloatPointable floatp = (FloatPointable) FloatPointable.FACTORY.createPointable();
+ IntegerPointable intp = (IntegerPointable) IntegerPointable.FACTORY.createPointable();
+ LongPointable longp = (LongPointable) LongPointable.FACTORY.createPointable();
+ ShortPointable shortp = (ShortPointable) ShortPointable.FACTORY.createPointable();
+ UTF8StringPointable utf8sp = (UTF8StringPointable) UTF8StringPointable.FACTORY.createPointable();
+ XSDecimalPointable decp = (XSDecimalPointable) XSDecimalPointable.FACTORY.createPointable();
+ }
+}
Propchange: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/node/FnNumberScalarEvaluatorFactory.java
------------------------------------------------------------------------------
svn:eol-style = native