http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java index 9c4fb41..0f4ebee 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/EditDistanceListIsFilterableDescriptor.java @@ -92,8 +92,8 @@ public class EditDistanceListIsFilterableDescriptor extends AbstractScalarFuncti protected final IScalarEvaluator edThreshEval; @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ABoolean> booleanSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private final ISerializerDeserializer<ABoolean> booleanSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); public EditDistanceListIsFilterableEvaluator(IScalarEvaluatorFactory[] args, IHyracksTaskContext context) throws HyracksDataException { @@ -122,16 +122,15 @@ public class EditDistanceListIsFilterableDescriptor extends AbstractScalarFuncti listLen = AOrderedListSerializerDeserializer.getNumberOfItems(bytes, offset); break; default: - throw new TypeMismatchException(BuiltinFunctions.EDIT_DISTANCE_LIST_IS_FILTERABLE, - 0, ATypeTag.SERIALIZED_UNORDEREDLIST_TYPE_TAG, - ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG); + throw new TypeMismatchException(BuiltinFunctions.EDIT_DISTANCE_LIST_IS_FILTERABLE, 0, + ATypeTag.SERIALIZED_UNORDEREDLIST_TYPE_TAG, ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG); } // Check type and extract edit-distance threshold. bytes = edThreshPtr.getByteArray(); offset = edThreshPtr.getStartOffset(); - long edThresh = ATypeHierarchy.getIntegerValue( - BuiltinFunctions.EDIT_DISTANCE_LIST_IS_FILTERABLE.getName(), 1, bytes, offset); + long edThresh = ATypeHierarchy.getIntegerValue(BuiltinFunctions.EDIT_DISTANCE_LIST_IS_FILTERABLE.getName(), + 1, bytes, offset); // Compute result. long lowerBound = listLen - edThresh;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsDescriptor.java index 48541cb..810f6c4 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsDescriptor.java @@ -47,10 +47,10 @@ public class FullTextContainsDescriptor extends AbstractScalarFunctionDynamicDes public static final String CONJUNCTIVE_SEARCH_MODE_OPTION = "all"; private static final byte[] SEARCH_MODE_OPTION_ARRAY = UTF8StringUtil.writeStringToBytes(SEARCH_MODE_OPTION); - private static final byte[] DISJUNCTIVE_SEARCH_MODE_OPTION_ARRAY = UTF8StringUtil - .writeStringToBytes(DISJUNCTIVE_SEARCH_MODE_OPTION); - private static final byte[] CONJUNCTIVE_SEARCH_MODE_OPTION_ARRAY = UTF8StringUtil - .writeStringToBytes(CONJUNCTIVE_SEARCH_MODE_OPTION); + private static final byte[] DISJUNCTIVE_SEARCH_MODE_OPTION_ARRAY = + UTF8StringUtil.writeStringToBytes(DISJUNCTIVE_SEARCH_MODE_OPTION); + private static final byte[] CONJUNCTIVE_SEARCH_MODE_OPTION_ARRAY = + UTF8StringUtil.writeStringToBytes(CONJUNCTIVE_SEARCH_MODE_OPTION); static { paramTypeMap.put(SEARCH_MODE_OPTION, ATypeTag.STRING); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsWithoutOptionDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsWithoutOptionDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsWithoutOptionDescriptor.java index 7cfaa62..6ab87ac 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsWithoutOptionDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/FullTextContainsWithoutOptionDescriptor.java @@ -64,5 +64,4 @@ public class FullTextContainsWithoutOptionDescriptor extends AbstractScalarFunct return BuiltinFunctions.FULLTEXT_CONTAINS_WO_OPTION; } - } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GramTokensDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GramTokensDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GramTokensDescriptor.java index ec545ff..190013b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GramTokensDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/GramTokensDescriptor.java @@ -56,8 +56,8 @@ public class GramTokensDescriptor extends AbstractScalarFunctionDynamicDescripto @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { ITokenFactory tokenFactory = new UTF8NGramTokenFactory(); - NGramUTF8StringBinaryTokenizer tokenizer = new NGramUTF8StringBinaryTokenizer(3, true, true, true, - tokenFactory); + NGramUTF8StringBinaryTokenizer tokenizer = + new NGramUTF8StringBinaryTokenizer(3, true, true, true, tokenFactory); return new GramTokensEvaluator(args, ctx, tokenizer, BuiltinType.ASTRING); } }; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/HashedGramTokensDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/HashedGramTokensDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/HashedGramTokensDescriptor.java index 49d9f27..32dc292 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/HashedGramTokensDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/HashedGramTokensDescriptor.java @@ -56,8 +56,8 @@ public class HashedGramTokensDescriptor extends AbstractScalarFunctionDynamicDes @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { ITokenFactory tokenFactory = new HashedUTF8NGramTokenFactory(); - NGramUTF8StringBinaryTokenizer tokenizer = new NGramUTF8StringBinaryTokenizer(3, true, true, true, - tokenFactory); + NGramUTF8StringBinaryTokenizer tokenizer = + new NGramUTF8StringBinaryTokenizer(3, true, true, true, tokenFactory); return new GramTokensEvaluator(args, ctx, tokenizer, BuiltinType.AINT32); } }; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java index cc0ae77..4268fc7 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/LenDescriptor.java @@ -71,8 +71,8 @@ public class LenDescriptor extends AbstractScalarFunctionDynamicDescriptor { // result private final AMutableInt64 res = new AMutableInt64(0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt64> int64Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private final ISerializerDeserializer<AInt64> int64Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); @Override public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { @@ -83,8 +83,8 @@ public class LenDescriptor extends AbstractScalarFunctionDynamicDescriptor { if (serList[offset] != ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG && serList[offset] != ATypeTag.SERIALIZED_UNORDEREDLIST_TYPE_TAG) { - throw new TypeMismatchException(getIdentifier(), 0, - serList[offset], ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG, + throw new TypeMismatchException(getIdentifier(), 0, serList[offset], + ATypeTag.SERIALIZED_ORDEREDLIST_TYPE_TAG, ATypeTag.SERIALIZED_UNORDEREDLIST_TYPE_TAG); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericATan2Descriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericATan2Descriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericATan2Descriptor.java index 6b15167..40cb659 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericATan2Descriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericATan2Descriptor.java @@ -72,8 +72,8 @@ public class NumericATan2Descriptor extends AbstractScalarFunctionDynamicDescrip // For the output. private final AMutableDouble aDouble = new AMutableDouble(0.0); @SuppressWarnings("rawtypes") - private final ISerializerDeserializer outputSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADOUBLE); + private final ISerializerDeserializer outputSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADOUBLE); private final ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); private final DataOutput out = resultStorage.getDataOutput(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCaretDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCaretDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCaretDescriptor.java index 642bf71..3b72072 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCaretDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericCaretDescriptor.java @@ -43,7 +43,7 @@ public class NumericCaretDescriptor extends AbstractNumericArithmeticEval { */ @Override protected long evaluateInteger(long lhs, long rhs) throws HyracksDataException { - if(rhs > Integer.MAX_VALUE){ + if (rhs > Integer.MAX_VALUE) { throw new ArithmeticException("Exponent cannot be larger than 2^31-1"); } return LongMath.checkedPow(lhs, (int) rhs); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericDivideDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericDivideDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericDivideDescriptor.java index b6f9117..7cda149 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericDivideDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericDivideDescriptor.java @@ -46,7 +46,7 @@ public class NumericDivideDescriptor extends AbstractNumericArithmeticEval { if (rhs == 0) { throw new ArithmeticException("Division by Zero."); } - if ( (lhs == Long.MIN_VALUE) && (rhs == -1L) ) { + if ((lhs == Long.MIN_VALUE) && (rhs == -1L)) { throw new ArithmeticException(("Overflow in integer division")); } return lhs / rhs; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericTruncDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericTruncDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericTruncDescriptor.java index e2cf5e7..fb52641 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericTruncDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/NumericTruncDescriptor.java @@ -118,9 +118,9 @@ public class NumericTruncDescriptor extends AbstractScalarFunctionDynamicDescrip } else if (bytes[offset] == ATypeTag.SERIALIZED_INT64_TYPE_TAG) { return (int) AInt64SerializerDeserializer.getLong(bytes, offset + 1); } else { - throw new TypeMismatchException(getIdentifier(), 1, bytes[offset], - ATypeTag.SERIALIZED_INT8_TYPE_TAG, ATypeTag.SERIALIZED_INT16_TYPE_TAG, - ATypeTag.SERIALIZED_INT32_TYPE_TAG, ATypeTag.SERIALIZED_INT64_TYPE_TAG); + throw new TypeMismatchException(getIdentifier(), 1, bytes[offset], ATypeTag.SERIALIZED_INT8_TYPE_TAG, + ATypeTag.SERIALIZED_INT16_TYPE_TAG, ATypeTag.SERIALIZED_INT32_TYPE_TAG, + ATypeTag.SERIALIZED_INT64_TYPE_TAG); } } @@ -178,10 +178,10 @@ public class NumericTruncDescriptor extends AbstractScalarFunctionDynamicDescrip serde.serialize(aDouble, out); } } else { - throw new TypeMismatchException(getIdentifier(), 0, data[offset], - ATypeTag.SERIALIZED_INT8_TYPE_TAG, ATypeTag.SERIALIZED_INT16_TYPE_TAG, - ATypeTag.SERIALIZED_INT32_TYPE_TAG, ATypeTag.SERIALIZED_INT64_TYPE_TAG, - ATypeTag.SERIALIZED_FLOAT_TYPE_TAG, ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG); + throw new TypeMismatchException(getIdentifier(), 0, data[offset], ATypeTag.SERIALIZED_INT8_TYPE_TAG, + ATypeTag.SERIALIZED_INT16_TYPE_TAG, ATypeTag.SERIALIZED_INT32_TYPE_TAG, + ATypeTag.SERIALIZED_INT64_TYPE_TAG, ATypeTag.SERIALIZED_FLOAT_TYPE_TAG, + ATypeTag.SERIALIZED_DOUBLE_TYPE_TAG); } result.set(resultStorage); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java index 362d808..c9a865b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenDescriptor.java @@ -49,8 +49,8 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference; public class PrefixLenDescriptor extends AbstractScalarFunctionDynamicDescriptor { private static final long serialVersionUID = 1L; - private final static FunctionIdentifier FID = new FunctionIdentifier(FunctionConstants.ASTERIX_NS, "prefix-len@3", - 3); + 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() { @@ -80,8 +80,8 @@ public class PrefixLenDescriptor extends AbstractScalarFunctionDynamicDescriptor // result private final AMutableInt32 res = new AMutableInt32(0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt32> int32Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT32); + private final ISerializerDeserializer<AInt32> int32Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT32); @Override public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { @@ -115,8 +115,8 @@ public class PrefixLenDescriptor extends AbstractScalarFunctionDynamicDescriptor throw new TypeMismatchException(getIdentifier(), 2, data[offset], ATypeTag.SERIALIZED_STRING_TYPE_TAG); } - SimilarityFilters similarityFilters = similarityFiltersCache.get(similarityThreshold, data, - offset, len); + SimilarityFilters similarityFilters = + similarityFiltersCache.get(similarityThreshold, data, offset, len); int prefixLength = similarityFilters.getPrefixLength(length); res.setValue(prefixLength); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java index 5a67121..25d4be3 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/PrefixLenJaccardDescriptor.java @@ -78,8 +78,8 @@ public class PrefixLenJaccardDescriptor extends AbstractScalarFunctionDynamicDes // result private final AMutableInt32 res = new AMutableInt32(0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt32> int32Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT32); + private final ISerializerDeserializer<AInt32> int32Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT32); @Override public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SimilarityJaccardPrefixCheckDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SimilarityJaccardPrefixCheckDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SimilarityJaccardPrefixCheckDescriptor.java index 2d88402..e1b5f3f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SimilarityJaccardPrefixCheckDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SimilarityJaccardPrefixCheckDescriptor.java @@ -73,11 +73,11 @@ public class SimilarityJaccardPrefixCheckDescriptor extends AbstractScalarFuncti private final OrderedListBuilder listBuilder; private ArrayBackedValueStorage inputVal; @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ABoolean> booleanSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private final ISerializerDeserializer<ABoolean> booleanSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AFloat> floatSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AFLOAT); + private final ISerializerDeserializer<AFloat> floatSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AFLOAT); private final AMutableFloat aFloat = new AMutableFloat(0); private final AOrderedListType listType = new AOrderedListType(BuiltinType.ANY, "list"); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SpatialIntersectDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SpatialIntersectDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SpatialIntersectDescriptor.java index 6edbf6f..4229f87 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SpatialIntersectDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SpatialIntersectDescriptor.java @@ -92,14 +92,14 @@ public class SpatialIntersectDescriptor extends AbstractScalarFunctionDynamicDes private boolean pointOnLine(double pX, double pY, double startX, double startY, double endX, double endY) throws HyracksDataException { - double crossProduct = SpatialUtils.crossProduct(pY - startY, pX - startX, endY - startY, - endX - startX); + double crossProduct = + SpatialUtils.crossProduct(pY - startY, pX - startX, endY - startY, endX - startX); if (Math.abs(crossProduct) > SpatialUtils.doubleEpsilon()) { // crossProduct != 0 return false; } - double dotProduct = SpatialUtils.dotProduct((pX - startX), (pY - startY), (endX - startX), - (endY - startY)); + double dotProduct = + SpatialUtils.dotProduct((pX - startX), (pY - startY), (endX - startX), (endY - startY)); if (dotProduct < 0.0) { return false; } @@ -536,8 +536,8 @@ public class SpatialIntersectDescriptor extends AbstractScalarFunctionDynamicDes min1 = spatialUtils.getMinProjection(); max1 = spatialUtils.getMaxProjection(); - dotProduct = SpatialUtils.dotProduct(spatialUtils.getXAxis(), spatialUtils.getYAxis(), cX, - cY); + dotProduct = + SpatialUtils.dotProduct(spatialUtils.getXAxis(), spatialUtils.getYAxis(), cX, cY); max2 = dotProduct + radius; min2 = dotProduct - radius; @@ -687,9 +687,9 @@ public class SpatialIntersectDescriptor extends AbstractScalarFunctionDynamicDes trianglesX1.reset(); trianglesY1.reset(); while (true) { - middleVertex1 = triangulatePolygon(bytes1, offset1, numOfPoints1, pointsOffsets1, - trianglesX1, trianglesY1, numOfTriangles1, nonSimplePolygonDetection1, - middleVertex1); + middleVertex1 = + triangulatePolygon(bytes1, offset1, numOfPoints1, pointsOffsets1, trianglesX1, + trianglesY1, numOfTriangles1, nonSimplePolygonDetection1, middleVertex1); if (middleVertex1 == -1) { break; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringContainsDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringContainsDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringContainsDescriptor.java index f55ef3d..46865cf 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringContainsDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringContainsDescriptor.java @@ -49,8 +49,7 @@ public class StringContainsDescriptor extends AbstractScalarFunctionDynamicDescr @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { - return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], - BuiltinFunctions.STRING_CONTAINS) { + return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], BuiltinFunctions.STRING_CONTAINS) { @Override protected boolean compute(UTF8StringPointable left, UTF8StringPointable right) throws IOException { return UTF8StringPointable.contains(left, right, false); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEndsWithDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEndsWithDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEndsWithDescriptor.java index ab0cfd3..6422158 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEndsWithDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEndsWithDescriptor.java @@ -49,8 +49,7 @@ public class StringEndsWithDescriptor extends AbstractScalarFunctionDynamicDescr @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { - return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], - BuiltinFunctions.STRING_ENDS_WITH) { + return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], BuiltinFunctions.STRING_ENDS_WITH) { @Override protected boolean compute(UTF8StringPointable left, UTF8StringPointable right) throws IOException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEqualDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEqualDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEqualDescriptor.java index 6a7ad51..71a5742 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEqualDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringEqualDescriptor.java @@ -49,8 +49,7 @@ public class StringEqualDescriptor extends AbstractScalarFunctionDynamicDescript @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { - return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], - BuiltinFunctions.STRING_EQUAL) { + return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], BuiltinFunctions.STRING_EQUAL) { @Override protected boolean compute(UTF8StringPointable left, UTF8StringPointable right) throws IOException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringLengthDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringLengthDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringLengthDescriptor.java index 58d63d1..bf62316 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringLengthDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringLengthDescriptor.java @@ -66,8 +66,8 @@ public class StringLengthDescriptor extends AbstractScalarFunctionDynamicDescrip private IPointable inputArg = new VoidPointable(); private IScalarEvaluator eval = args[0].createScalarEvaluator(ctx); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInt64> int64Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private ISerializerDeserializer<AInt64> int64Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); @Override public void evaluate(IFrameTupleReference tuple, IPointable resultPointable) @@ -83,8 +83,8 @@ public class StringLengthDescriptor extends AbstractScalarFunctionDynamicDescrip result.setValue(len); int64Serde.serialize(result, out); } else { - throw new TypeMismatchException(getIdentifier(), 0, - serString[offset], ATypeTag.SERIALIZED_STRING_TYPE_TAG); + throw new TypeMismatchException(getIdentifier(), 0, serString[offset], + ATypeTag.SERIALIZED_STRING_TYPE_TAG); } resultPointable.set(resultStorage); } catch (IOException e1) { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRTrim2Descriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRTrim2Descriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRTrim2Descriptor.java index 1c6b1f7..5d32bca 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRTrim2Descriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRTrim2Descriptor.java @@ -70,5 +70,4 @@ public class StringRTrim2Descriptor extends AbstractScalarFunctionDynamicDescrip }; } - } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRepeatDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRepeatDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRepeatDescriptor.java index fe864f4..77c4f20 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRepeatDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringRepeatDescriptor.java @@ -83,8 +83,8 @@ public class StringRepeatDescriptor extends AbstractScalarFunctionDynamicDescrip // Gets the repeating times. byte[] bytes = argNumber.getByteArray(); int offset = argNumber.getStartOffset(); - int repeatingTimes = ATypeHierarchy.getIntegerValue(getIdentifier().getName(), 1, bytes, - offset); + int repeatingTimes = + ATypeHierarchy.getIntegerValue(getIdentifier().getName(), 1, bytes, offset); // Checks repeatingTimes. It should be a non-negative value. if (repeatingTimes < 0) { throw new RuntimeDataException(ErrorCode.NEGATIVE_VALUE, getIdentifier(), 1, http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringSplitDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringSplitDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringSplitDescriptor.java index 7027343..f788366 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringSplitDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringSplitDescriptor.java @@ -117,8 +117,8 @@ public class StringSplitDescriptor extends AbstractScalarFunctionDynamicDescript // Gets the string length of the source string. int inputStringLen = UTF8StringUtil.getUTFLength(srcString, srcOffset + 1); - int inputStringStart = srcOffset + 1 - + UTF8StringUtil.getNumBytesToStoreLength(inputStringLen); + int inputStringStart = + srcOffset + 1 + UTF8StringUtil.getNumBytesToStoreLength(inputStringLen); // Gets the string length of the pattern string. int inputPatternLen = UTF8StringUtil.getUTFLength(patternString, patternOffset + 1); // Handles the case that the pattern is "". @@ -128,8 +128,8 @@ public class StringSplitDescriptor extends AbstractScalarFunctionDynamicDescript listBuilder.reset(intListType); int itemStrStart = 0; int nextMatchStart; - while (itemStrStart < inputStringLen && (nextMatchStart = UTF8StringPointable - .find(argStrPtr, argPatternPtr, false, itemStrStart)) >= 0) { + while (itemStrStart < inputStringLen && (nextMatchStart = + UTF8StringPointable.find(argStrPtr, argPatternPtr, false, itemStrStart)) >= 0) { // Adds an item string. addItemString(srcString, inputStringStart, itemStrStart, emptyStringPattern ? nextMatchStart + 1 : nextMatchStart); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringStartsWithDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringStartsWithDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringStartsWithDescriptor.java index 75ffeca..aa43e66 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringStartsWithDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringStartsWithDescriptor.java @@ -49,8 +49,7 @@ public class StringStartsWithDescriptor extends AbstractScalarFunctionDynamicDes @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { - return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], - BuiltinFunctions.STRING_STARTS_WITH) { + return new AbstractBinaryStringBoolEval(ctx, args[0], args[1], BuiltinFunctions.STRING_STARTS_WITH) { @Override protected boolean compute(UTF8StringPointable left, UTF8StringPointable right) throws IOException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringToCodePointDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringToCodePointDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringToCodePointDescriptor.java index fa06e4d..fe5ad9f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringToCodePointDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringToCodePointDescriptor.java @@ -74,8 +74,8 @@ public class StringToCodePointDescriptor extends AbstractScalarFunctionDynamicDe private ArrayBackedValueStorage inputVal = new ArrayBackedValueStorage(); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt64> int64Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private final ISerializerDeserializer<AInt64> int64Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); private final AMutableInt64 aInt64 = new AMutableInt64(0); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringTrimDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringTrimDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringTrimDescriptor.java index a459f42..bc4d150 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringTrimDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/StringTrimDescriptor.java @@ -68,5 +68,4 @@ public class StringTrimDescriptor extends AbstractScalarFunctionDynamicDescripto }; } - } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SubstringDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SubstringDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SubstringDescriptor.java index caaa11a..28bbe08 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SubstringDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/SubstringDescriptor.java @@ -103,8 +103,7 @@ public class SubstringDescriptor extends AbstractScalarFunctionDynamicDescriptor try { UTF8StringPointable.substr(string, start, len, builder, array); } catch (StringIndexOutOfBoundsException e) { - throw new RuntimeDataException(ErrorCode.OUT_OF_BOUND, getIdentifier(), 1, - start + len - 1); + throw new RuntimeDataException(ErrorCode.OUT_OF_BOUND, getIdentifier(), 1, start + len - 1); } catch (IOException e) { throw new HyracksDataException(e); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToBooleanDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToBooleanDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToBooleanDescriptor.java index ae6aca5..704630e 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToBooleanDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToBooleanDescriptor.java @@ -95,8 +95,7 @@ public class ToBooleanDescriptor extends AbstractScalarFunctionDynamicDescriptor setInteger(UTF8StringUtil.getStringLength(bytes, offset + 1), result); break; case ARRAY: - setInteger(AOrderedListSerializerDeserializer.getNumberOfItems(bytes, offset), - result); + setInteger(AOrderedListSerializerDeserializer.getNumberOfItems(bytes, offset), result); break; case MULTISET: setInteger(AUnorderedListSerializerDeserializer.getNumberOfItems(bytes, offset), http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToDoubleDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToDoubleDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToDoubleDescriptor.java index a7e4d94..71cdbe5 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToDoubleDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/ToDoubleDescriptor.java @@ -60,7 +60,7 @@ public class ToDoubleDescriptor extends AbstractScalarFunctionDynamicDescriptor return new AbstractDoubleConstructorEvaluator(args[0].createScalarEvaluator(ctx)) { @SuppressWarnings("unchecked") private final ISerializerDeserializer<ANull> nullSerde = - SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ANULL); + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ANULL); @Override protected void evaluateImpl(IPointable result) throws IOException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/UUIDDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/UUIDDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/UUIDDescriptor.java index e4980f1..a254738 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/UUIDDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/UUIDDescriptor.java @@ -57,8 +57,8 @@ public class UUIDDescriptor extends AbstractScalarFunctionDynamicDescriptor { private static final long serialVersionUID = 1L; @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AUUID> uuidSerDe = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AUUID); + private final ISerializerDeserializer<AUUID> uuidSerDe = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AUUID); @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractFindBinaryEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractFindBinaryEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractFindBinaryEvaluator.java index a1f097d..827b43e 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractFindBinaryEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractFindBinaryEvaluator.java @@ -41,8 +41,8 @@ public abstract class AbstractFindBinaryEvaluator extends AbstractBinaryScalarEv protected final ByteArrayPointable wordPtr = new ByteArrayPointable(); @SuppressWarnings("unchecked") - protected ISerializerDeserializer<AInt64> intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + protected ISerializerDeserializer<AInt64> intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); public AbstractFindBinaryEvaluator(IHyracksTaskContext context, IScalarEvaluatorFactory[] copyEvaluatorFactories, String functionName) throws HyracksDataException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractSubBinaryEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractSubBinaryEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractSubBinaryEvaluator.java index d777bc7..cd7b7d3 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractSubBinaryEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/AbstractSubBinaryEvaluator.java @@ -54,10 +54,10 @@ public abstract class AbstractSubBinaryEvaluator extends AbstractBinaryScalarEva } try { - ATypeTag argTag0 = ATypeTag.VALUE_TYPE_MAPPING[pointables[0].getByteArray()[pointables[0] - .getStartOffset()]]; - ATypeTag argTag1 = ATypeTag.VALUE_TYPE_MAPPING[pointables[1].getByteArray()[pointables[1] - .getStartOffset()]]; + ATypeTag argTag0 = + ATypeTag.VALUE_TYPE_MAPPING[pointables[0].getByteArray()[pointables[0].getStartOffset()]]; + ATypeTag argTag1 = + ATypeTag.VALUE_TYPE_MAPPING[pointables[1].getByteArray()[pointables[1].getStartOffset()]]; checkTypeMachingThrowsIfNot(functionName, EXPECTED_INPUT_TAGS, argTag0, argTag1); byteArrayPointable.set(pointables[0].getByteArray(), pointables[0].getStartOffset() + 1, @@ -68,8 +68,8 @@ public abstract class AbstractSubBinaryEvaluator extends AbstractBinaryScalarEva int subStart; // strange SQL index convention - subStart = ATypeHierarchy.getIntegerValue(BuiltinFunctions.SUBBINARY_FROM.getName(), 1, startBytes, - offset) - 1; + subStart = ATypeHierarchy.getIntegerValue(BuiltinFunctions.SUBBINARY_FROM.getName(), 1, startBytes, offset) + - 1; int totalLength = byteArrayPointable.getContentLength(); int subLength = getSubLength(tuple); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/BinaryLengthDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/BinaryLengthDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/BinaryLengthDescriptor.java index 41fb805..2c53225 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/BinaryLengthDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/BinaryLengthDescriptor.java @@ -60,8 +60,8 @@ public class BinaryLengthDescriptor extends AbstractScalarFunctionDynamicDescrip private AMutableInt64 result = new AMutableInt64(0); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInt64> intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private ISerializerDeserializer<AInt64> intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); @Override public void evaluate(IFrameTupleReference tuple, IPointable resultPointable) @@ -72,7 +72,7 @@ public class BinaryLengthDescriptor extends AbstractScalarFunctionDynamicDescrip .getStartOffset()]]; checkTypeMachingThrowsIfNot(getIdentifier().getName(), EXPECTED_TAGS, tag); int len = ByteArrayPointable.getContentLength(pointables[0].getByteArray(), - pointables[0].getStartOffset() + 1); + pointables[0].getStartOffset() + 1); result.setValue(len); intSerde.serialize(result, dataOutput); resultPointable.set(resultStorage); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/FindBinaryFromDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/FindBinaryFromDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/FindBinaryFromDescriptor.java index 299eaec..71f8459 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/FindBinaryFromDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/FindBinaryFromDescriptor.java @@ -57,8 +57,7 @@ public class FindBinaryFromDescriptor extends AbstractScalarFunctionDynamicDescr @Override protected int getFromOffset(IFrameTupleReference tuple) throws HyracksDataException { return ATypeHierarchy.getIntegerValue(getIdentifier().getName(), 2, - pointables[2].getByteArray(), - pointables[2].getStartOffset()); + pointables[2].getByteArray(), pointables[2].getStartOffset()); } }; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/ParseBinaryDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/ParseBinaryDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/ParseBinaryDescriptor.java index 36a0b1e..67d7b0f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/ParseBinaryDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/binary/ParseBinaryDescriptor.java @@ -70,8 +70,8 @@ public class ParseBinaryDescriptor extends AbstractScalarFunctionDynamicDescript return new AbstractBinaryScalarEvaluator(ctx, args) { @SuppressWarnings("unchecked") - private ISerializerDeserializer<ABinary> binarySerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABINARY); + private ISerializerDeserializer<ABinary> binarySerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABINARY); private AMutableBinary aBinary = new AMutableBinary(new byte[0], 0, 0); private final UTF8StringPointable stringPointable = new UTF8StringPointable(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/GetRecordFieldsEvalFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/GetRecordFieldsEvalFactory.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/GetRecordFieldsEvalFactory.java index 2019b55..9a3f3b9 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/GetRecordFieldsEvalFactory.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/GetRecordFieldsEvalFactory.java @@ -52,8 +52,8 @@ public class GetRecordFieldsEvalFactory implements IScalarEvaluatorFactory { public IScalarEvaluator createScalarEvaluator(final IHyracksTaskContext ctx) throws HyracksDataException { return new IScalarEvaluator() { - private final ARecordPointable recordPointable = (ARecordPointable) ARecordPointable.FACTORY - .createPointable(); + private final ARecordPointable recordPointable = + (ARecordPointable) ARecordPointable.FACTORY.createPointable(); private IPointable inputArg0 = new VoidPointable(); private IScalarEvaluator eval0 = recordEvalFactory.createScalarEvaluator(ctx); private ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordFieldsUtil.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordFieldsUtil.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordFieldsUtil.java index 6c0eb06..d93d572 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordFieldsUtil.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordFieldsUtil.java @@ -59,25 +59,25 @@ public class RecordFieldsUtil { private final static AString nestedName = new AString("nested"); private final static AString listName = new AString("list"); - private IObjectPool<IARecordBuilder, ATypeTag> recordBuilderPool = new ListObjectPool<IARecordBuilder, ATypeTag>( - new RecordBuilderFactory()); - private IObjectPool<IAsterixListBuilder, ATypeTag> listBuilderPool = new ListObjectPool<IAsterixListBuilder, ATypeTag>( - new ListBuilderFactory()); - private IObjectPool<IMutableValueStorage, ATypeTag> abvsBuilderPool = new ListObjectPool<IMutableValueStorage, ATypeTag>( - new AbvsBuilderFactory()); - private IObjectPool<IPointable, ATypeTag> recordPointablePool = new ListObjectPool<IPointable, ATypeTag>( - ARecordPointable.ALLOCATOR); - private IObjectPool<IPointable, ATypeTag> listPointablePool = new ListObjectPool<IPointable, ATypeTag>( - AListPointable.ALLOCATOR); + private IObjectPool<IARecordBuilder, ATypeTag> recordBuilderPool = + new ListObjectPool<IARecordBuilder, ATypeTag>(new RecordBuilderFactory()); + private IObjectPool<IAsterixListBuilder, ATypeTag> listBuilderPool = + new ListObjectPool<IAsterixListBuilder, ATypeTag>(new ListBuilderFactory()); + private IObjectPool<IMutableValueStorage, ATypeTag> abvsBuilderPool = + new ListObjectPool<IMutableValueStorage, ATypeTag>(new AbvsBuilderFactory()); + private IObjectPool<IPointable, ATypeTag> recordPointablePool = + new ListObjectPool<IPointable, ATypeTag>(ARecordPointable.ALLOCATOR); + private IObjectPool<IPointable, ATypeTag> listPointablePool = + new ListObjectPool<IPointable, ATypeTag>(AListPointable.ALLOCATOR); private final static AOrderedListType listType = new AOrderedListType(BuiltinType.ANY, "fields"); //Better not be a static object. @SuppressWarnings("unchecked") - protected final ISerializerDeserializer<AString> stringSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ASTRING); + protected final ISerializerDeserializer<AString> stringSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ASTRING); @SuppressWarnings("unchecked") - protected final ISerializerDeserializer<ABoolean> booleanSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + protected final ISerializerDeserializer<ABoolean> booleanSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); private final static ARecordType openType = DefaultOpenFieldType.NESTED_OPEN_RECORD_TYPE; @@ -175,8 +175,7 @@ public class RecordFieldsUtil { orderedListBuilder.write(out, true); } - public void addNameField(IValueReference nameArg, IARecordBuilder fieldRecordBuilder) - throws HyracksDataException { + public void addNameField(IValueReference nameArg, IARecordBuilder fieldRecordBuilder) throws HyracksDataException { ArrayBackedValueStorage fieldAbvs = getTempBuffer(); fieldAbvs.reset(); @@ -184,8 +183,7 @@ public class RecordFieldsUtil { fieldRecordBuilder.addField(fieldAbvs, nameArg); } - public void addFieldType(byte tagId, IARecordBuilder fieldRecordBuilder) - throws HyracksDataException { + public void addFieldType(byte tagId, IARecordBuilder fieldRecordBuilder) throws HyracksDataException { ArrayBackedValueStorage fieldAbvs = getTempBuffer(); ArrayBackedValueStorage valueAbvs = getTempBuffer(); @@ -201,8 +199,7 @@ public class RecordFieldsUtil { fieldRecordBuilder.addField(fieldAbvs, valueAbvs); } - public void addIsOpenField(boolean isOpen, IARecordBuilder fieldRecordBuilder) - throws HyracksDataException { + public void addIsOpenField(boolean isOpen, IARecordBuilder fieldRecordBuilder) throws HyracksDataException { ArrayBackedValueStorage fieldAbvs = getTempBuffer(); ArrayBackedValueStorage valueAbvs = getTempBuffer(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeDescriptor.java index 63b58ed..9ff670f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeDescriptor.java @@ -131,7 +131,7 @@ public class RecordMergeDescriptor extends AbstractScalarFunctionDynamicDescript try { mergeFields(outRecType, rp0, rp1, true, 0); rbStack.get(0).write(out, true); - } catch (IOException e) { + } catch (IOException e) { throw new HyracksDataException(e); } result.set(resultStorage); @@ -168,8 +168,7 @@ public class RecordMergeDescriptor extends AbstractScalarFunctionDynamicDescript openFromParent, nestedLevel); foundMatch = true; } else { - throw new RuntimeDataException(ErrorCode.DUPLICATE_FIELD_NAME, - getIdentifier()); + throw new RuntimeDataException(ErrorCode.DUPLICATE_FIELD_NAME, getIdentifier()); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordPairsDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordPairsDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordPairsDescriptor.java index e5ed628..2bf2530 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordPairsDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordPairsDescriptor.java @@ -108,8 +108,8 @@ public class RecordPairsDescriptor extends AbstractScalarFunctionDynamicDescript return new IScalarEvaluator() { private final IScalarEvaluator argEvaluator = args[0].createScalarEvaluator(ctx); private final IPointable argPtr = new VoidPointable(); - private final ARecordVisitablePointable recordVisitablePointable = new ARecordVisitablePointable( - recType); + private final ARecordVisitablePointable recordVisitablePointable = + new ARecordVisitablePointable(recType); @Override public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordRemoveFieldsEvalFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordRemoveFieldsEvalFactory.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordRemoveFieldsEvalFactory.java index 74f7259..192a14b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordRemoveFieldsEvalFactory.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordRemoveFieldsEvalFactory.java @@ -125,8 +125,7 @@ class RecordRemoveFieldsEvalFactory implements IScalarEvaluatorFactory { } private void processRecord(ARecordType requiredType, ARecordVisitablePointable srp, - AListVisitablePointable inputList, int nestedLevel) - throws IOException { + AListVisitablePointable inputList, int nestedLevel) throws IOException { if (rbStack.size() < (nestedLevel + 1)) { rbStack.add(new RecordBuilder()); } @@ -156,8 +155,7 @@ class RecordRemoveFieldsEvalFactory implements IScalarEvaluatorFactory { private void addKeptFieldToSubRecord(ARecordType requiredType, IVisitablePointable fieldNamePointable, IVisitablePointable fieldValuePointable, IVisitablePointable fieldTypePointable, - AListVisitablePointable inputList, int nestedLevel) - throws IOException { + AListVisitablePointable inputList, int nestedLevel) throws IOException { runtimeRecordTypeInfo.reset(requiredType); int pos = runtimeRecordTypeInfo.getFieldIndex(fieldNamePointable.getByteArray(), http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/AbstractIntervalLogicFuncDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/AbstractIntervalLogicFuncDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/AbstractIntervalLogicFuncDescriptor.java index fb7b235..0a1bcf5 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/AbstractIntervalLogicFuncDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/AbstractIntervalLogicFuncDescriptor.java @@ -54,21 +54,21 @@ public abstract class AbstractIntervalLogicFuncDescriptor extends AbstractScalar protected final IntervalLogic il = new IntervalLogic(); private ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); private DataOutput out = resultStorage.getDataOutput(); - private TaggedValuePointable argPtr0 = (TaggedValuePointable) TaggedValuePointable.FACTORY - .createPointable(); - private TaggedValuePointable argPtr1 = (TaggedValuePointable) TaggedValuePointable.FACTORY - .createPointable(); - private AIntervalPointable interval0 = (AIntervalPointable) AIntervalPointable.FACTORY - .createPointable(); - private AIntervalPointable interval1 = (AIntervalPointable) AIntervalPointable.FACTORY - .createPointable(); + private TaggedValuePointable argPtr0 = + (TaggedValuePointable) TaggedValuePointable.FACTORY.createPointable(); + private TaggedValuePointable argPtr1 = + (TaggedValuePointable) TaggedValuePointable.FACTORY.createPointable(); + private AIntervalPointable interval0 = + (AIntervalPointable) AIntervalPointable.FACTORY.createPointable(); + private AIntervalPointable interval1 = + (AIntervalPointable) AIntervalPointable.FACTORY.createPointable(); private IScalarEvaluator eval0 = args[0].createScalarEvaluator(ctx); private IScalarEvaluator eval1 = args[1].createScalarEvaluator(ctx); // possible output types @SuppressWarnings("unchecked") - private ISerializerDeserializer<ABoolean> booleanSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private ISerializerDeserializer<ABoolean> booleanSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); @Override public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDuartionFromDateDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDuartionFromDateDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDuartionFromDateDescriptor.java index a06b440..3dab641 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDuartionFromDateDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDuartionFromDateDescriptor.java @@ -75,8 +75,8 @@ public class CalendarDuartionFromDateDescriptor extends AbstractScalarFunctionDy private IScalarEvaluator eval1 = args[1].createScalarEvaluator(ctx); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADuration> durationSerde = SerializerDeserializerProvider. - INSTANCE.getSerializerDeserializer(BuiltinType.ADURATION); + private ISerializerDeserializer<ADuration> durationSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADURATION); private AMutableDuration aDuration = new AMutableDuration(0, 0); @@ -103,8 +103,8 @@ public class CalendarDuartionFromDateDescriptor extends AbstractScalarFunctionDy ATypeTag.SERIALIZED_DURATION_TYPE_TAG); } - int yearMonthDurationInMonths = ADurationSerializerDeserializer.getYearMonth(bytes1, - offset1 + 1); + int yearMonthDurationInMonths = + ADurationSerializerDeserializer.getYearMonth(bytes1, offset1 + 1); long dayTimeDurationInMs = ADurationSerializerDeserializer.getDayTime(bytes1, offset1 + 1); long startingTimePoint = ADateSerializerDeserializer.getChronon(bytes0, offset0 + 1) @@ -174,8 +174,7 @@ public class CalendarDuartionFromDateDescriptor extends AbstractScalarFunctionDy boolean isLeapYear = calInstanct.isLeapYear(year1); // need to "borrow" the days in previous month to make the day positive; when month is // 1 (Jan), Dec will be borrowed - day += isLeapYear - ? (GregorianCalendarSystem.DAYS_OF_MONTH_LEAP[(12 + month1 - 2) % 12]) + day += isLeapYear ? (GregorianCalendarSystem.DAYS_OF_MONTH_LEAP[(12 + month1 - 2) % 12]) : (GregorianCalendarSystem.DAYS_OF_MONTH_ORDI[(12 + month1 - 2) % 12]); month -= 1; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDurationFromDateTimeDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDurationFromDateTimeDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDurationFromDateTimeDescriptor.java index 904200e..867d030 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDurationFromDateTimeDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CalendarDurationFromDateTimeDescriptor.java @@ -92,8 +92,8 @@ public class CalendarDurationFromDateTimeDescriptor extends AbstractScalarFuncti private IScalarEvaluator eval1 = args[1].createScalarEvaluator(ctx); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADuration> durationSerde = SerializerDeserializerProvider. - INSTANCE.getSerializerDeserializer(BuiltinType.ADURATION); + private ISerializerDeserializer<ADuration> durationSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADURATION); private AMutableDuration aDuration = new AMutableDuration(0, 0); @@ -120,8 +120,8 @@ public class CalendarDurationFromDateTimeDescriptor extends AbstractScalarFuncti ATypeTag.SERIALIZED_DURATION_TYPE_TAG); } - int yearMonthDurationInMonths = ADurationSerializerDeserializer.getYearMonth(bytes1, - offset1 + 1); + int yearMonthDurationInMonths = + ADurationSerializerDeserializer.getYearMonth(bytes1, offset1 + 1); long dayTimeDurationInMs = ADurationSerializerDeserializer.getDayTime(bytes1, offset1 + 1); long startingTimePoint = ADateTimeSerializerDeserializer.getChronon(bytes0, offset0 + 1); @@ -188,8 +188,7 @@ public class CalendarDurationFromDateTimeDescriptor extends AbstractScalarFuncti boolean isLeapYear = calInstanct.isLeapYear(year1); // need to "borrow" the days in previous month to make the day positive; when month is // 1 (Jan), Dec will be borrowed - day += isLeapYear - ? (GregorianCalendarSystem.DAYS_OF_MONTH_LEAP[(12 + month1 - 2) % 12]) + day += isLeapYear ? (GregorianCalendarSystem.DAYS_OF_MONTH_LEAP[(12 + month1 - 2) % 12]) : (GregorianCalendarSystem.DAYS_OF_MONTH_ORDI[(12 + month1 - 2) % 12]); month -= 1; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateDescriptor.java index 2174432..8d4cff5 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateDescriptor.java @@ -66,8 +66,8 @@ public class CurrentDateDescriptor extends AbstractScalarFunctionDynamicDescript private DataOutput out = resultStorage.getDataOutput(); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADate> dateSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADATE); + private ISerializerDeserializer<ADate> dateSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATE); private AMutableDate aDate = new AMutableDate(0); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateTimeDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateTimeDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateTimeDescriptor.java index 9c284b5..5491c39 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateTimeDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentDateTimeDescriptor.java @@ -67,8 +67,8 @@ public class CurrentDateTimeDescriptor extends AbstractScalarFunctionDynamicDesc private DataOutput out = resultStorage.getDataOutput(); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADateTime> datetimeSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADATETIME); + private ISerializerDeserializer<ADateTime> datetimeSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATETIME); private AMutableDateTime aDateTime = new AMutableDateTime(0); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentTimeDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentTimeDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentTimeDescriptor.java index 3ce0e5a..f9cfbf2 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentTimeDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/CurrentTimeDescriptor.java @@ -68,8 +68,8 @@ public class CurrentTimeDescriptor extends AbstractScalarFunctionDynamicDescript private DataOutput out = resultStorage.getDataOutput(); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ATime> timeSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ATIME); + private ISerializerDeserializer<ATime> timeSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ATIME); private AMutableTime aTime = new AMutableTime(0); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromDatetimeDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromDatetimeDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromDatetimeDescriptor.java index 557591e..cfac2e9 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromDatetimeDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromDatetimeDescriptor.java @@ -72,8 +72,8 @@ public class DateFromDatetimeDescriptor extends AbstractScalarFunctionDynamicDes // possible returning types @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADate> dateSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADATE); + private ISerializerDeserializer<ADate> dateSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATE); private AMutableDate aDate = new AMutableDate(0); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromUnixTimeInDaysDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromUnixTimeInDaysDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromUnixTimeInDaysDescriptor.java index 09c74e0..a365989 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromUnixTimeInDaysDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DateFromUnixTimeInDaysDescriptor.java @@ -70,8 +70,8 @@ public class DateFromUnixTimeInDaysDescriptor extends AbstractScalarFunctionDyna // possible returning types @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADate> dateSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADATE); + private ISerializerDeserializer<ADate> dateSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATE); @Override public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DatetimeFromDateAndTimeDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DatetimeFromDateAndTimeDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DatetimeFromDateAndTimeDescriptor.java index 87ef5d2..f70a6e2 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DatetimeFromDateAndTimeDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/temporal/DatetimeFromDateAndTimeDescriptor.java @@ -77,8 +77,8 @@ public class DatetimeFromDateAndTimeDescriptor extends AbstractScalarFunctionDyn // possible returning types @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADateTime> datetimeSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADATETIME); + private ISerializerDeserializer<ADateTime> datetimeSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATETIME); private AMutableDateTime aDateTime = new AMutableDateTime(0); @Override
