You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by am...@apache.org on 2016/02/01 09:31:24 UTC
[05/13] incubator-asterixdb git commit: Add Support for Upsert
Operation
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePolygonDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePolygonDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePolygonDescriptor.java
index c46c8bf..bba4478 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePolygonDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePolygonDescriptor.java
@@ -46,11 +46,8 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class CreatePolygonDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
-
- private static final byte SER_ORDEREDLIST_TYPE_TAG = ATypeTag.ORDEREDLIST.serialize();
- private final static byte SER_POLYGON_TYPE_TAG = ATypeTag.POLYGON.serialize();
-
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new CreatePolygonDescriptor();
}
@@ -81,7 +78,7 @@ public class CreatePolygonDescriptor extends AbstractScalarFunctionDynamicDescri
outInputList.reset();
evalList.evaluate(tuple);
byte[] listBytes = outInputList.getByteArray();
- if (listBytes[0] != SER_ORDEREDLIST_TYPE_TAG) {
+ if (listBytes[0] != ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG) {
throw new AlgebricksException(AsterixBuiltinFunctions.CREATE_POLYGON.getName()
+ ": expects input type ORDEREDLIST, but got "
+ EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(listBytes[0]));
@@ -113,17 +110,17 @@ public class CreatePolygonDescriptor extends AbstractScalarFunctionDynamicDescri
throw new AlgebricksException(
"There must be an even number of double values in the list to form a polygon");
}
- out.writeByte(SER_POLYGON_TYPE_TAG);
+ out.writeByte(ATypeTag.SERIALIZED_POLYGON_TYPE_TAG);
out.writeShort(listAccessor.size() / 2);
for (int i = 0; i < listAccessor.size() / 2; i++) {
int firstDoubleOffset = listAccessor.getItemOffset(i * 2);
int secondDobuleOffset = listAccessor.getItemOffset((i * 2) + 1);
- APointSerializerDeserializer
- .serialize(ADoubleSerializerDeserializer.getDouble(listBytes,
- firstDoubleOffset), ADoubleSerializerDeserializer.getDouble(
- listBytes, secondDobuleOffset), out);
+ APointSerializerDeserializer.serialize(
+ ADoubleSerializerDeserializer.getDouble(listBytes, firstDoubleOffset),
+ ADoubleSerializerDeserializer.getDouble(listBytes, secondDobuleOffset),
+ out);
}
} catch (AsterixException ex) {
throw new AlgebricksException(ex);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GetItemDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GetItemDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GetItemDescriptor.java
index 4848957..ab58da2 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GetItemDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GetItemDescriptor.java
@@ -47,6 +47,7 @@ public class GetItemDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new GetItemDescriptor();
}
@@ -68,8 +69,6 @@ public class GetItemDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private ICopyEvaluatorFactory listEvalFactory;
private ICopyEvaluatorFactory indexEvalFactory;
- private final static byte SER_ORDEREDLIST_TYPE_TAG = ATypeTag.ORDEREDLIST.serialize();
- private final static byte SER_NULL_TYPE_TAG = ATypeTag.NULL.serialize();
private byte serItemTypeTag;
private ATypeTag itemTag;
private boolean selfDescList = false;
@@ -105,30 +104,28 @@ public class GetItemDescriptor extends AbstractScalarFunctionDynamicDescriptor {
evalIdx.evaluate(tuple);
byte[] serOrderedList = outInputList.getByteArray();
- if (serOrderedList[0] == SER_NULL_TYPE_TAG) {
+ if (serOrderedList[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
nullSerde.serialize(ANull.NULL, out);
return;
}
- if (serOrderedList[0] == SER_ORDEREDLIST_TYPE_TAG) {
+ if (serOrderedList[0] == ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG) {
itemIndex = ATypeHierarchy.getIntegerValue(outInputIdx.getByteArray(), 0);
} else {
- throw new AlgebricksException(
- AsterixBuiltinFunctions.GET_ITEM.getName()
- + ": expects input type (NULL/ORDEREDLIST, [INT8/16/32/64/FLOAT/DOUBLE]), but got ("
- + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(serOrderedList[0])
- + ", "
- + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(outInputIdx
- .getByteArray()[0]) + ").");
+ throw new AlgebricksException(AsterixBuiltinFunctions.GET_ITEM.getName()
+ + ": expects input type (NULL/ORDEREDLIST, [INT8/16/32/64/FLOAT/DOUBLE]), but got ("
+ + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(serOrderedList[0]) + ", "
+ + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(outInputIdx.getByteArray()[0])
+ + ").");
}
if (itemIndex >= AOrderedListSerializerDeserializer.getNumberOfItems(serOrderedList)) {
- out.writeByte(SER_NULL_TYPE_TAG);
+ out.writeByte(ATypeTag.SERIALIZED_NULL_TYPE_TAG);
return;
}
if (itemIndex < 0)
- throw new AlgebricksException(AsterixBuiltinFunctions.GET_ITEM.getName()
- + ": item index cannot be negative!");
+ throw new AlgebricksException(
+ AsterixBuiltinFunctions.GET_ITEM.getName() + ": item index cannot be negative!");
itemTag = EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(serOrderedList[1]);
if (itemTag == ATypeTag.ANY)
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/IsNullDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/IsNullDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/IsNullDescriptor.java
index e3c793a..17065e8 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/IsNullDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/IsNullDescriptor.java
@@ -37,10 +37,7 @@ import org.apache.hyracks.data.std.util.ArrayBackedValueStorage;
import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class IsNullDescriptor extends AbstractScalarFunctionDynamicDescriptor {
-
private static final long serialVersionUID = 1L;
-
- private final static byte SER_NULL_TYPE_TAG = ATypeTag.NULL.serialize();
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
@Override
public IFunctionDescriptor createFunctionDescriptor() {
@@ -67,7 +64,8 @@ public class IsNullDescriptor extends AbstractScalarFunctionDynamicDescriptor {
public void evaluate(IFrameTupleReference tuple) throws AlgebricksException {
argOut.reset();
eval.evaluate(tuple);
- boolean isNull = argOut.getByteArray()[argOut.getStartOffset()] == SER_NULL_TYPE_TAG;
+ boolean isNull = argOut.getByteArray()[argOut
+ .getStartOffset()] == ATypeTag.SERIALIZED_NULL_TYPE_TAG;
ABoolean res = isNull ? ABoolean.TRUE : ABoolean.FALSE;
try {
aObjSerDer.serialize(res, out);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java
index c0d91b2..bfe6a5c 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java
@@ -45,12 +45,9 @@ import org.apache.hyracks.data.std.util.ArrayBackedValueStorage;
import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class LenDescriptor extends AbstractScalarFunctionDynamicDescriptor {
-
private static final long serialVersionUID = 1L;
- private final static byte SER_ORDEREDLIST_TYPE_TAG = ATypeTag.ORDEREDLIST.serialize();
- private final static byte SER_UNORDEREDLIST_TYPE_TAG = ATypeTag.UNORDEREDLIST.serialize();
- private final static byte SER_NULL_TYPE_TAG = ATypeTag.NULL.serialize();
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new LenDescriptor();
}
@@ -87,7 +84,7 @@ public class LenDescriptor extends AbstractScalarFunctionDynamicDescriptor {
byte[] serList = inputVal.getByteArray();
- if (serList[0] == SER_NULL_TYPE_TAG) {
+ if (serList[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
try {
nullSerde.serialize(ANull.NULL, out);
} catch (HyracksDataException e) {
@@ -96,14 +93,15 @@ public class LenDescriptor extends AbstractScalarFunctionDynamicDescriptor {
return;
}
- if (serList[0] != SER_ORDEREDLIST_TYPE_TAG && serList[0] != SER_UNORDEREDLIST_TYPE_TAG) {
+ if (serList[0] != ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG
+ && serList[0] != ATypeTag.SERIALIZED_UNORDEREDLIST_TYPE_TAG) {
throw new AlgebricksException(AsterixBuiltinFunctions.LEN.getName()
+ ": expects input type ORDEREDLIST/UNORDEREDLIST but got "
+ EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(serList[0]));
}
int numberOfitems = 0;
- if (serList[0] == SER_ORDEREDLIST_TYPE_TAG)
+ if (serList[0] == ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG)
numberOfitems = AOrderedListSerializerDeserializer.getNumberOfItems(serList);
else
numberOfitems = AUnorderedListSerializerDeserializer.getNumberOfItems(serList);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotDescriptor.java
index 06c29a9..1f97509 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotDescriptor.java
@@ -41,12 +41,9 @@ import org.apache.hyracks.data.std.util.ArrayBackedValueStorage;
import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class NotDescriptor extends AbstractScalarFunctionDynamicDescriptor {
-
private static final long serialVersionUID = 1L;
-
- private final static byte SER_BOOLEAN_TYPE_TAG = ATypeTag.BOOLEAN.serialize();
- private final static byte SER_NULL_TYPE_TAG = ATypeTag.NULL.serialize();
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NotDescriptor();
}
@@ -85,11 +82,11 @@ public class NotDescriptor extends AbstractScalarFunctionDynamicDescriptor {
argOut.reset();
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == SER_BOOLEAN_TYPE_TAG) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_BOOLEAN_TYPE_TAG) {
boolean argRes = ABooleanSerializerDeserializer.getBoolean(argOut.getByteArray(), 1);
ABoolean aResult = argRes ? (ABoolean.FALSE) : (ABoolean.TRUE);
booleanSerde.serialize(aResult, out);
- } else if (argOut.getByteArray()[0] == SER_NULL_TYPE_TAG)
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG)
nullSerde.serialize(ANull.NULL, out);
else
throw new AlgebricksException(errorMessage);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotNullDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotNullDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotNullDescriptor.java
index 16b875c..b0e3640 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotNullDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NotNullDescriptor.java
@@ -44,11 +44,11 @@ public class NotNullDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NotNullDescriptor();
}
};
- private final static byte SER_NULL_TYPE_TAG = ATypeTag.NULL.serialize();
@Override
public ICopyEvaluatorFactory createEvaluatorFactory(final ICopyEvaluatorFactory[] args) {
@@ -71,7 +71,7 @@ public class NotNullDescriptor extends AbstractScalarFunctionDynamicDescriptor {
outInput.reset();
eval.evaluate(tuple);
byte[] data = outInput.getByteArray();
- if (data[outInput.getStartOffset()] == SER_NULL_TYPE_TAG) {
+ if (data[outInput.getStartOffset()] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
throw new AlgebricksException(errorMessage);
}
out.write(data, outInput.getStartOffset(), outInput.getLength());
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericAbsDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericAbsDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericAbsDescriptor.java
index 79cacac..d1f6a2d 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericAbsDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericAbsDescriptor.java
@@ -60,6 +60,7 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class NumericAbsDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NumericAbsDescriptor();
}
@@ -83,13 +84,6 @@ public class NumericAbsDescriptor extends AbstractScalarFunctionDynamicDescripto
private DataOutput out = output.getDataOutput();
private ArrayBackedValueStorage argOut = new ArrayBackedValueStorage();
private ICopyEvaluator eval = args[0].createEvaluator(argOut);
- private byte serNullTypeTag = ATypeTag.NULL.serialize();
- private byte serInt8TypeTag = ATypeTag.INT8.serialize();
- private byte serInt16TypeTag = ATypeTag.INT16.serialize();
- private byte serInt32TypeTag = ATypeTag.INT32.serialize();
- private byte serInt64TypeTag = ATypeTag.INT64.serialize();
- private byte serFloatTypeTag = ATypeTag.FLOAT.serialize();
- private byte serDoubleTypeTag = ATypeTag.DOUBLE.serialize();
private AMutableDouble aDouble = new AMutableDouble(0);
private AMutableFloat aFloat = new AMutableFloat(0);
@@ -106,44 +100,44 @@ public class NumericAbsDescriptor extends AbstractScalarFunctionDynamicDescripto
argOut.reset();
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == serNullTypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ANULL);
serde.serialize(ANull.NULL, out);
- } else if (argOut.getByteArray()[0] == serInt8TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT8);
- byte val = (byte) AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
+ byte val = AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
aInt8.setValue((val <= 0) ? (byte) (0 - val) : val);
serde.serialize(aInt8, out);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT16);
- short val = (short) AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
+ short val = AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
aInt16.setValue((val <= 0) ? (short) (0 - val) : val);
serde.serialize(aInt16, out);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT32);
- int val = (int) AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
+ int val = AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
aInt32.setValue((val <= 0) ? (0 - val) : val);
serde.serialize(aInt32, out);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT64);
- long val = (long) AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
+ long val = AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
aInt64.setValue((val <= 0L) ? (0L - val) : val);
serde.serialize(aInt64, out);
- } else if (argOut.getByteArray()[0] == serFloatTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_FLOAT_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AFLOAT);
- float val = (float) AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
+ float val = AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
aFloat.setValue((val <= 0.0f) ? 0.0f - val : val);
serde.serialize(aFloat, out);
- } else if (argOut.getByteArray()[0] == serDoubleTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ADOUBLE);
- double val = (double) ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
+ double val = ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
aDouble.setValue((val <= 0.0D) ? 0.0D - val : val);
serde.serialize(aDouble, out);
} else {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCeilingDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCeilingDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCeilingDescriptor.java
index e77b287..ed4353a 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCeilingDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCeilingDescriptor.java
@@ -61,6 +61,7 @@ public class NumericCeilingDescriptor extends AbstractScalarFunctionDynamicDescr
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NumericCeilingDescriptor();
}
@@ -80,18 +81,9 @@ public class NumericCeilingDescriptor extends AbstractScalarFunctionDynamicDescr
public ICopyEvaluator createEvaluator(final IDataOutputProvider output) throws AlgebricksException {
return new ICopyEvaluator() {
-
private DataOutput out = output.getDataOutput();
private ArrayBackedValueStorage argOut = new ArrayBackedValueStorage();
private ICopyEvaluator eval = args[0].createEvaluator(argOut);
- private byte serNullTypeTag = ATypeTag.NULL.serialize();
- private byte serInt8TypeTag = ATypeTag.INT8.serialize();
- private byte serInt16TypeTag = ATypeTag.INT16.serialize();
- private byte serInt32TypeTag = ATypeTag.INT32.serialize();
- private byte serInt64TypeTag = ATypeTag.INT64.serialize();
- private byte serFloatTypeTag = ATypeTag.FLOAT.serialize();
- private byte serDoubleTypeTag = ATypeTag.DOUBLE.serialize();
-
private AMutableDouble aDouble = new AMutableDouble(0);
private AMutableFloat aFloat = new AMutableFloat(0);
private AMutableInt64 aInt64 = new AMutableInt64(0);
@@ -107,44 +99,44 @@ public class NumericCeilingDescriptor extends AbstractScalarFunctionDynamicDescr
argOut.reset();
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == serNullTypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ANULL);
serde.serialize(ANull.NULL, out);
- } else if (argOut.getByteArray()[0] == serInt8TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT8);
- byte val = (byte) AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
+ byte val = AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
aInt8.setValue(val);
serde.serialize(aInt8, out);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT16);
- short val = (short) AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
+ short val = AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
aInt16.setValue(val);
serde.serialize(aInt16, out);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT32);
- int val = (int) AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
+ int val = AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
aInt32.setValue(val);
serde.serialize(aInt32, out);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT64);
- long val = (long) AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
+ long val = AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
aInt64.setValue(val);
serde.serialize(aInt64, out);
- } else if (argOut.getByteArray()[0] == serFloatTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_FLOAT_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AFLOAT);
- float val = (float) AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
+ float val = AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
aFloat.setValue((float) Math.ceil(val));
serde.serialize(aFloat, out);
- } else if (argOut.getByteArray()[0] == serDoubleTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ADOUBLE);
- double val = (double) ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
+ double val = ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
aDouble.setValue(Math.ceil(val));
serde.serialize(aDouble, out);
} else {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericFloorDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericFloorDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericFloorDescriptor.java
index 834f2c9..c9f1974 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericFloorDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericFloorDescriptor.java
@@ -60,6 +60,7 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class NumericFloorDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NumericFloorDescriptor();
}
@@ -83,14 +84,6 @@ public class NumericFloorDescriptor extends AbstractScalarFunctionDynamicDescrip
private DataOutput out = output.getDataOutput();
private ArrayBackedValueStorage argOut = new ArrayBackedValueStorage();
private ICopyEvaluator eval = args[0].createEvaluator(argOut);
- private byte serNullTypeTag = ATypeTag.NULL.serialize();
- private byte serInt8TypeTag = ATypeTag.INT8.serialize();
- private byte serInt16TypeTag = ATypeTag.INT16.serialize();
- private byte serInt32TypeTag = ATypeTag.INT32.serialize();
- private byte serInt64TypeTag = ATypeTag.INT64.serialize();
- private byte serFloatTypeTag = ATypeTag.FLOAT.serialize();
- private byte serDoubleTypeTag = ATypeTag.DOUBLE.serialize();
-
private AMutableDouble aDouble = new AMutableDouble(0);
private AMutableFloat aFloat = new AMutableFloat(0);
private AMutableInt64 aInt64 = new AMutableInt64(0);
@@ -106,44 +99,44 @@ public class NumericFloorDescriptor extends AbstractScalarFunctionDynamicDescrip
argOut.reset();
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == serNullTypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ANULL);
serde.serialize(ANull.NULL, out);
- } else if (argOut.getByteArray()[0] == serInt8TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT8);
- byte val = (byte) AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
+ byte val = AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
aInt8.setValue(val);
serde.serialize(aInt8, out);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT16);
- short val = (short) AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
+ short val = AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
aInt16.setValue(val);
serde.serialize(aInt16, out);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT32);
- int val = (int) AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
+ int val = AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
aInt32.setValue(val);
serde.serialize(aInt32, out);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT64);
- long val = (long) AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
+ long val = AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
aInt64.setValue(val);
serde.serialize(aInt64, out);
- } else if (argOut.getByteArray()[0] == serFloatTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_FLOAT_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AFLOAT);
- float val = (float) AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
+ float val = AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
aFloat.setValue((float) Math.floor(val));
serde.serialize(aFloat, out);
- } else if (argOut.getByteArray()[0] == serDoubleTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ADOUBLE);
- double val = (double) ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
+ double val = ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
aDouble.setValue(Math.floor(val));
serde.serialize(aDouble, out);
} else {
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundDescriptor.java
index b78c13d..23bfad8 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundDescriptor.java
@@ -60,6 +60,7 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class NumericRoundDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NumericRoundDescriptor();
}
@@ -83,14 +84,6 @@ public class NumericRoundDescriptor extends AbstractScalarFunctionDynamicDescrip
private DataOutput out = output.getDataOutput();
private ArrayBackedValueStorage argOut = new ArrayBackedValueStorage();
private ICopyEvaluator eval = args[0].createEvaluator(argOut);
- private byte serNullTypeTag = ATypeTag.NULL.serialize();
- private byte serInt8TypeTag = ATypeTag.INT8.serialize();
- private byte serInt16TypeTag = ATypeTag.INT16.serialize();
- private byte serInt32TypeTag = ATypeTag.INT32.serialize();
- private byte serInt64TypeTag = ATypeTag.INT64.serialize();
- private byte serFloatTypeTag = ATypeTag.FLOAT.serialize();
- private byte serDoubleTypeTag = ATypeTag.DOUBLE.serialize();
-
private AMutableDouble aDouble = new AMutableDouble(0);
private AMutableFloat aFloat = new AMutableFloat(0);
private AMutableInt64 aInt64 = new AMutableInt64(0);
@@ -106,45 +99,45 @@ public class NumericRoundDescriptor extends AbstractScalarFunctionDynamicDescrip
argOut.reset();
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == serNullTypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ANULL);
serde.serialize(ANull.NULL, out);
- } else if (argOut.getByteArray()[0] == serInt8TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT8);
- byte val = (byte) AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
+ byte val = AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
aInt8.setValue(val);
serde.serialize(aInt8, out);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT16);
- short val = (short) AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
+ short val = AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
aInt16.setValue(val);
serde.serialize(aInt16, out);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT32);
- int val = (int) AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
+ int val = AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
aInt32.setValue(val);
serde.serialize(aInt32, out);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT64);
- long val = (long) AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
+ long val = AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
aInt64.setValue(val);
serde.serialize(aInt64, out);
- } else if (argOut.getByteArray()[0] == serFloatTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_FLOAT_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AFLOAT);
- float val = (float) AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
+ float val = AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
val = Math.round(val);
aFloat.setValue(val);
serde.serialize(aFloat, out);
- } else if (argOut.getByteArray()[0] == serDoubleTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ADOUBLE);
- double val = (double) ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
+ double val = ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
val = Math.round(val);
aDouble.setValue(val);
serde.serialize(aDouble, out);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEven2Descriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEven2Descriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEven2Descriptor.java
index e448252..cdf9115 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEven2Descriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEven2Descriptor.java
@@ -62,6 +62,7 @@ public class NumericRoundHalfToEven2Descriptor extends AbstractScalarFunctionDyn
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NumericRoundHalfToEven2Descriptor();
}
@@ -86,15 +87,6 @@ public class NumericRoundHalfToEven2Descriptor extends AbstractScalarFunctionDyn
private ArrayBackedValueStorage argOut = new ArrayBackedValueStorage();
private ICopyEvaluator eval = args[0].createEvaluator(argOut);
private ICopyEvaluator precision = args[1].createEvaluator(argOut);
-
- private byte serNullTypeTag = ATypeTag.NULL.serialize();
- private byte serInt8TypeTag = ATypeTag.INT8.serialize();
- private byte serInt16TypeTag = ATypeTag.INT16.serialize();
- private byte serInt32TypeTag = ATypeTag.INT32.serialize();
- private byte serInt64TypeTag = ATypeTag.INT64.serialize();
- private byte serFloatTypeTag = ATypeTag.FLOAT.serialize();
- private byte serDoubleTypeTag = ATypeTag.DOUBLE.serialize();
-
private AMutableDouble aDouble = new AMutableDouble(0);
private AMutableFloat aFloat = new AMutableFloat(0);
private AMutableInt64 aInt64 = new AMutableInt64(0);
@@ -108,13 +100,13 @@ public class NumericRoundHalfToEven2Descriptor extends AbstractScalarFunctionDyn
argOut.reset();
precision.evaluate(tuple);
- if (argOut.getByteArray()[0] == serInt8TypeTag) {
- return (int) AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
- return (int) AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
- return (int) AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
+ return AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
+ return AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
+ return AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
return (int) AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
} else {
throw new AlgebricksException(AsterixBuiltinFunctions.NUMERIC_ROUND_HALF_TO_EVEN2.getName()
@@ -129,66 +121,64 @@ public class NumericRoundHalfToEven2Descriptor extends AbstractScalarFunctionDyn
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == serNullTypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ANULL);
serde.serialize(ANull.NULL, out);
- } else if (argOut.getByteArray()[0] == serInt8TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT8);
- byte val = (byte) AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
+ byte val = AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
aInt8.setValue(val);
serde.serialize(aInt8, out);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT16);
- short val = (short) AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
+ short val = AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
aInt16.setValue(val);
serde.serialize(aInt16, out);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT32);
- int val = (int) AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
+ int val = AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
aInt32.setValue(val);
serde.serialize(aInt32, out);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT64);
- long val = (long) AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
+ long val = AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
aInt64.setValue(val);
serde.serialize(aInt64, out);
- } else if (argOut.getByteArray()[0] == serFloatTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_FLOAT_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AFLOAT);
- float val = (float) AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
+ float val = AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
if (Float.isNaN(val) || Float.isInfinite(val) || val == -0.0F || val == 0.0F) {
aFloat.setValue(val);
serde.serialize(aFloat, out);
} else {
BigDecimal r = new BigDecimal(Float.toString(val));
- aFloat.setValue(r.setScale(getPrecision(tuple), BigDecimal.ROUND_HALF_EVEN)
- .floatValue());
+ aFloat.setValue(
+ r.setScale(getPrecision(tuple), BigDecimal.ROUND_HALF_EVEN).floatValue());
serde.serialize(aFloat, out);
}
- } else if (argOut.getByteArray()[0] == serDoubleTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ADOUBLE);
- double val = (double) ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
+ double val = ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
if (Double.isNaN(val) || Double.isInfinite(val) || val == -0.0D || val == 0.0D) {
aDouble.setValue(val);
serde.serialize(aDouble, out);
} else {
BigDecimal r = new BigDecimal(Double.toString(val));
- aDouble.setValue(r.setScale(getPrecision(tuple), BigDecimal.ROUND_HALF_EVEN)
- .doubleValue());
+ aDouble.setValue(
+ r.setScale(getPrecision(tuple), BigDecimal.ROUND_HALF_EVEN).doubleValue());
serde.serialize(aDouble, out);
}
} else {
- throw new NotImplementedException(
- AsterixBuiltinFunctions.NUMERIC_ROUND_HALF_TO_EVEN2.getName()
- + ": not implemented for "
- + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argOut
- .getByteArray()[0]));
+ throw new NotImplementedException(AsterixBuiltinFunctions.NUMERIC_ROUND_HALF_TO_EVEN2
+ .getName() + ": not implemented for "
+ + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argOut.getByteArray()[0]));
}
} catch (HyracksDataException e) {
throw new AlgebricksException(e);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEvenDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEvenDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEvenDescriptor.java
index 06e36c8..edae3fe 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEvenDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericRoundHalfToEvenDescriptor.java
@@ -60,6 +60,7 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class NumericRoundHalfToEvenDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NumericRoundHalfToEvenDescriptor();
}
@@ -83,14 +84,6 @@ public class NumericRoundHalfToEvenDescriptor extends AbstractScalarFunctionDyna
private DataOutput out = output.getDataOutput();
private ArrayBackedValueStorage argOut = new ArrayBackedValueStorage();
private ICopyEvaluator eval = args[0].createEvaluator(argOut);
- private byte serNullTypeTag = ATypeTag.NULL.serialize();
- private byte serInt8TypeTag = ATypeTag.INT8.serialize();
- private byte serInt16TypeTag = ATypeTag.INT16.serialize();
- private byte serInt32TypeTag = ATypeTag.INT32.serialize();
- private byte serInt64TypeTag = ATypeTag.INT64.serialize();
- private byte serFloatTypeTag = ATypeTag.FLOAT.serialize();
- private byte serDoubleTypeTag = ATypeTag.DOUBLE.serialize();
-
private AMutableDouble aDouble = new AMutableDouble(0);
private AMutableFloat aFloat = new AMutableFloat(0);
private AMutableInt64 aInt64 = new AMutableInt64(0);
@@ -106,53 +99,51 @@ public class NumericRoundHalfToEvenDescriptor extends AbstractScalarFunctionDyna
argOut.reset();
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == serNullTypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ANULL);
serde.serialize(ANull.NULL, out);
return;
- } else if (argOut.getByteArray()[0] == serInt8TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT8);
- byte val = (byte) AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
+ byte val = AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1);
aInt8.setValue(val);
serde.serialize(aInt8, out);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT16);
- short val = (short) AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
+ short val = AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1);
aInt16.setValue(val);
serde.serialize(aInt16, out);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT32);
- int val = (int) AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
+ int val = AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1);
aInt32.setValue(val);
serde.serialize(aInt32, out);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT64);
- long val = (long) AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
+ long val = AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1);
aInt64.setValue(val);
serde.serialize(aInt64, out);
- } else if (argOut.getByteArray()[0] == serFloatTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_FLOAT_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AFLOAT);
- float val = (float) AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
+ float val = AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1);
aFloat.setValue((float) Math.rint(val));
serde.serialize(aFloat, out);
- } else if (argOut.getByteArray()[0] == serDoubleTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ADOUBLE);
- double val = (double) ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
+ double val = ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1);
aDouble.setValue(Math.rint(val));
serde.serialize(aDouble, out);
} else {
- throw new NotImplementedException(
- AsterixBuiltinFunctions.NUMERIC_ROUND_HALF_TO_EVEN.getName()
- + ": not implemented for "
- + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argOut
- .getByteArray()[0]));
+ throw new NotImplementedException(AsterixBuiltinFunctions.NUMERIC_ROUND_HALF_TO_EVEN
+ .getName() + ": not implemented for "
+ + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argOut.getByteArray()[0]));
}
} catch (HyracksDataException e) {
throw new AlgebricksException(e);
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericUnaryMinusDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericUnaryMinusDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericUnaryMinusDescriptor.java
index ff1e5b4..ba60873 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericUnaryMinusDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericUnaryMinusDescriptor.java
@@ -56,6 +56,7 @@ public class NumericUnaryMinusDescriptor extends AbstractScalarFunctionDynamicDe
private static final long serialVersionUID = 1L;
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new NumericUnaryMinusDescriptor();
}
@@ -74,13 +75,6 @@ public class NumericUnaryMinusDescriptor extends AbstractScalarFunctionDynamicDe
private DataOutput out = output.getDataOutput();
private ArrayBackedValueStorage argOut = new ArrayBackedValueStorage();
private ICopyEvaluator eval = args[0].createEvaluator(argOut);
- private byte serNullTypeTag = ATypeTag.NULL.serialize();
- private byte serInt8TypeTag = ATypeTag.INT8.serialize();
- private byte serInt16TypeTag = ATypeTag.INT16.serialize();
- private byte serInt32TypeTag = ATypeTag.INT32.serialize();
- private byte serInt64TypeTag = ATypeTag.INT64.serialize();
- private byte serFloatTypeTag = ATypeTag.FLOAT.serialize();
- private byte serDoubleTypeTag = ATypeTag.DOUBLE.serialize();
private AMutableDouble aDouble = new AMutableDouble(0);
private AMutableFloat aFloat = new AMutableFloat(0);
private AMutableInt64 aInt64 = new AMutableInt64(0);
@@ -96,37 +90,38 @@ public class NumericUnaryMinusDescriptor extends AbstractScalarFunctionDynamicDe
argOut.reset();
eval.evaluate(tuple);
try {
- if (argOut.getByteArray()[0] == serNullTypeTag) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ANULL);
serde.serialize(ANull.NULL, out);
return;
- } else if (argOut.getByteArray()[0] == serInt8TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT8_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT8);
aInt8.setValue((byte) -AInt8SerializerDeserializer.getByte(argOut.getByteArray(), 1));
serde.serialize(aInt8, out);
- } else if (argOut.getByteArray()[0] == serInt16TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT16_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT16);
- aInt16.setValue((short) -AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1));
+ aInt16.setValue(
+ (short) -AInt16SerializerDeserializer.getShort(argOut.getByteArray(), 1));
serde.serialize(aInt16, out);
- } else if (argOut.getByteArray()[0] == serInt32TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT32);
aInt32.setValue(-AInt32SerializerDeserializer.getInt(argOut.getByteArray(), 1));
serde.serialize(aInt32, out);
- } else if (argOut.getByteArray()[0] == serInt64TypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AINT64);
aInt64.setValue(-AInt64SerializerDeserializer.getLong(argOut.getByteArray(), 1));
serde.serialize(aInt64, out);
- } else if (argOut.getByteArray()[0] == serFloatTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_FLOAT_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.AFLOAT);
aFloat.setValue(-AFloatSerializerDeserializer.getFloat(argOut.getByteArray(), 1));
serde.serialize(aFloat, out);
- } else if (argOut.getByteArray()[0] == serDoubleTypeTag) {
+ } else if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
serde = AqlSerializerDeserializerProvider.INSTANCE
.getSerializerDeserializer(BuiltinType.ADOUBLE);
aDouble.setValue(-ADoubleSerializerDeserializer.getDouble(argOut.getByteArray(), 1));
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/OrDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/OrDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/OrDescriptor.java
index 73adb7b..f6ea1f2 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/OrDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/OrDescriptor.java
@@ -39,10 +39,9 @@ import org.apache.hyracks.data.std.util.ArrayBackedValueStorage;
import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class OrDescriptor extends AbstractScalarFunctionDynamicDescriptor {
-
private static final long serialVersionUID = 1L;
- private final static byte SER_NULL_TYPE_TAG = ATypeTag.NULL.serialize();
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new OrDescriptor();
}
@@ -85,7 +84,7 @@ public class OrDescriptor extends AbstractScalarFunctionDynamicDescriptor {
for (int i = 0; i < n; i++) {
argOut.reset();
evals[i].evaluate(tuple);
- if (argOut.getByteArray()[0] == SER_NULL_TYPE_TAG) {
+ if (argOut.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
metNull = true;
continue;
}
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java
index 29603da..af8ab19 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java
@@ -47,15 +47,10 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
public class PrefixLenDescriptor extends AbstractScalarFunctionDynamicDescriptor {
private static final long serialVersionUID = 1L;
-
- // allowed input types
- private final static byte SER_INT32_TYPE_TAG = ATypeTag.INT32.serialize();
- private final static byte SER_DOUBLE_TYPE_TAG = ATypeTag.DOUBLE.serialize();
- private final static byte SER_STRING_TYPE_TAG = ATypeTag.STRING.serialize();
-
private final static FunctionIdentifier FID = new FunctionIdentifier(FunctionConstants.ASTERIX_NS, "prefix-len@3",
3);
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new PrefixLenDescriptor();
}
@@ -91,7 +86,7 @@ public class PrefixLenDescriptor extends AbstractScalarFunctionDynamicDescriptor
// length
inputVal.reset();
evalLen.evaluate(tuple);
- if (inputVal.getByteArray()[0] != SER_INT32_TYPE_TAG) {
+ if (inputVal.getByteArray()[0] != ATypeTag.SERIALIZED_INT32_TYPE_TAG) {
throw new AlgebricksException(FID.getName()
+ ": expects type Int32 for the first argument, but got "
+ EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(inputVal.getByteArray()[0]));
@@ -101,18 +96,18 @@ public class PrefixLenDescriptor extends AbstractScalarFunctionDynamicDescriptor
// similarity threshold
inputVal.reset();
evalThreshold.evaluate(tuple);
- if (inputVal.getByteArray()[0] != SER_DOUBLE_TYPE_TAG) {
+ if (inputVal.getByteArray()[0] != ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG) {
throw new AlgebricksException(FID.getName()
+ ": expects type DOUBLE for the second argument, but got "
+ EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(inputVal.getByteArray()[0]));
}
- float similarityThreshold = (float) ADoubleSerializerDeserializer.getDouble(
- inputVal.getByteArray(), 1);
+ float similarityThreshold = (float) ADoubleSerializerDeserializer
+ .getDouble(inputVal.getByteArray(), 1);
// similarity name
inputVal.reset();
evalSimilarity.evaluate(tuple);
- if (inputVal.getByteArray()[0] != SER_STRING_TYPE_TAG) {
+ if (inputVal.getByteArray()[0] != ATypeTag.SERIALIZED_STRING_TYPE_TAG) {
throw new AlgebricksException(FID.getName()
+ ": expects type STRING for the third argument, but got "
+ EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(inputVal.getByteArray()[0]));
http://git-wip-us.apache.org/repos/asf/incubator-asterixdb/blob/5dc958ce/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/RegExpDescriptor.java
----------------------------------------------------------------------
diff --git a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/RegExpDescriptor.java b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/RegExpDescriptor.java
index 1271465..82071e3 100644
--- a/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/RegExpDescriptor.java
+++ b/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/RegExpDescriptor.java
@@ -56,14 +56,9 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference;
*/
public class RegExpDescriptor extends AbstractScalarFunctionDynamicDescriptor {
-
private static final long serialVersionUID = 1L;
-
- // allowed input types
- private final static byte SER_NULL_TYPE_TAG = ATypeTag.NULL.serialize();
- private final static byte SER_STRING_TYPE_TAG = ATypeTag.STRING.serialize();
-
public static final IFunctionDescriptorFactory FACTORY = new IFunctionDescriptorFactory() {
+ @Override
public IFunctionDescriptor createFunctionDescriptor() {
return new RegExpDescriptor();
}
@@ -114,11 +109,11 @@ public class RegExpDescriptor extends AbstractScalarFunctionDynamicDescriptor {
try {
array0.reset();
evalPattern.evaluate(tuple);
- if (array0.getByteArray()[0] == SER_NULL_TYPE_TAG) {
+ if (array0.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
nullSerde.serialize(ANull.NULL, dout);
return;
}
- if (array0.getByteArray()[0] != SER_STRING_TYPE_TAG) {
+ if (array0.getByteArray()[0] != ATypeTag.SERIALIZED_STRING_TYPE_TAG) {
throw new AlgebricksException(AsterixBuiltinFunctions.REG_EXP.getName()
+ ": expects type STRING/NULL for the first input argument but got "
+ EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(array0.getByteArray()[0]));
@@ -138,19 +133,19 @@ public class RegExpDescriptor extends AbstractScalarFunctionDynamicDescriptor {
lastPattern.reset();
lastPattern.write(array0.getByteArray(), array0.getStartOffset(), array0.getLength());
// ! object creation !
- DataInputStream di = new DataInputStream(new ByteArrayInputStream(
- lastPattern.getByteArray()));
- AString strPattern = (AString) stringSerde.deserialize(di);
+ DataInputStream di = new DataInputStream(
+ new ByteArrayInputStream(lastPattern.getByteArray()));
+ AString strPattern = stringSerde.deserialize(di);
pattern = Pattern.compile(strPattern.getStringValue());
}
array0.reset();
evalString.evaluate(tuple);
- if (array0.getByteArray()[0] == SER_NULL_TYPE_TAG) {
+ if (array0.getByteArray()[0] == ATypeTag.SERIALIZED_NULL_TYPE_TAG) {
nullSerde.serialize(ANull.NULL, dout);
return;
}
- if (array0.getByteArray()[0] != SER_STRING_TYPE_TAG) {
+ if (array0.getByteArray()[0] != ATypeTag.SERIALIZED_STRING_TYPE_TAG) {
throw new AlgebricksException(AsterixBuiltinFunctions.REG_EXP.getName()
+ ": expects type STRING/NULL for the second input argument but got "
+ EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(array0.getByteArray()[0]));