http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartAccessor.java index 0c9639f..04da6d2 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartAccessor.java @@ -75,16 +75,16 @@ public class TemporalIntervalStartAccessor extends AbstractScalarFunctionDynamic // possible output @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ADate> dateSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADATE); + private final ISerializerDeserializer<ADate> dateSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATE); private final AMutableDate aDate = new AMutableDate(0); @SuppressWarnings("unchecked") private final ISerializerDeserializer<ADateTime> datetimeSerde = SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATETIME); private final AMutableDateTime aDateTime = new AMutableDateTime(0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ATime> timeSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ATIME); + private final ISerializerDeserializer<ATime> timeSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ATIME); private final AMutableTime aTime = new AMutableTime(0); @Override @@ -96,10 +96,10 @@ public class TemporalIntervalStartAccessor extends AbstractScalarFunctionDynamic resultStorage.reset(); try { if (bytes[startOffset] == ATypeTag.SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); - long startTime = AIntervalSerializerDeserializer.getIntervalStart(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); + long startTime = + AIntervalSerializerDeserializer.getIntervalStart(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_DATE_TYPE_TAG) { aDate.setValue((int) (startTime)); dateSerde.serialize(aDate, out);
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDateAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDateAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDateAccessor.java index f3a6dfd..971fd13 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDateAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDateAccessor.java @@ -73,8 +73,8 @@ public class TemporalIntervalStartDateAccessor extends AbstractScalarFunctionDyn // possible output @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ADate> dateSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADATE); + private final ISerializerDeserializer<ADate> dateSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADATE); private final AMutableDate aDate = new AMutableDate(0); @Override @@ -86,10 +86,10 @@ public class TemporalIntervalStartDateAccessor extends AbstractScalarFunctionDyn resultStorage.reset(); try { if (bytes[startOffset] == SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); - long startTime = AIntervalSerializerDeserializer.getIntervalStart(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); + long startTime = + AIntervalSerializerDeserializer.getIntervalStart(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_DATE_TYPE_TAG) { aDate.setValue((int) (startTime)); dateSerde.serialize(aDate, out); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDatetimeAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDatetimeAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDatetimeAccessor.java index 61aeaff..d785e90 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDatetimeAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartDatetimeAccessor.java @@ -83,10 +83,10 @@ public class TemporalIntervalStartDatetimeAccessor extends AbstractScalarFunctio resultStorage.reset(); try { if (bytes[startOffset] == ATypeTag.SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); - long startTime = AIntervalSerializerDeserializer.getIntervalStart(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); + long startTime = + AIntervalSerializerDeserializer.getIntervalStart(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_DATETIME_TYPE_TAG) { aDateTime.setValue(startTime); datetimeSerde.serialize(aDateTime, out); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartTimeAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartTimeAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartTimeAccessor.java index 649f7b9..2075b95 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartTimeAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalStartTimeAccessor.java @@ -71,8 +71,8 @@ public class TemporalIntervalStartTimeAccessor extends AbstractScalarFunctionDyn // possible output @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ATime> timeSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ATIME); + private final ISerializerDeserializer<ATime> timeSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ATIME); private final AMutableTime aTime = new AMutableTime(0); @Override @@ -84,10 +84,10 @@ public class TemporalIntervalStartTimeAccessor extends AbstractScalarFunctionDyn resultStorage.reset(); try { if (bytes[startOffset] == ATypeTag.SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); - long startTime = AIntervalSerializerDeserializer.getIntervalStart(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); + long startTime = + AIntervalSerializerDeserializer.getIntervalStart(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_TIME_TYPE_TAG) { aTime.setValue((int) (startTime)); timeSerde.serialize(aTime, out); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMillisecondAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMillisecondAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMillisecondAccessor.java index 9777d0a..292f410 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMillisecondAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMillisecondAccessor.java @@ -79,8 +79,8 @@ public class TemporalMillisecondAccessor extends AbstractScalarFunctionDynamicDe // for output: type integer @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt64> intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private final ISerializerDeserializer<AInt64> intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); private final AMutableInt64 aMutableInt64 = 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/accessors/TemporalMinuteAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMinuteAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMinuteAccessor.java index eb264e1..a92344b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMinuteAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMinuteAccessor.java @@ -82,8 +82,8 @@ public class TemporalMinuteAccessor extends AbstractScalarFunctionDynamicDescrip // for output: type integer @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt64> intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private final ISerializerDeserializer<AInt64> intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); private final AMutableInt64 aMutableInt64 = 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/accessors/TemporalMonthAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMonthAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMonthAccessor.java index da8333b..bbdc9a0 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMonthAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalMonthAccessor.java @@ -79,8 +79,8 @@ public class TemporalMonthAccessor extends AbstractScalarFunctionDynamicDescript // for output: type integer @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt64> intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private final ISerializerDeserializer<AInt64> intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); private final AMutableInt64 aMutableInt64 = 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/accessors/TemporalSecondAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalSecondAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalSecondAccessor.java index f8c3816..ecee642 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalSecondAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalSecondAccessor.java @@ -79,8 +79,8 @@ public class TemporalSecondAccessor extends AbstractScalarFunctionDynamicDescrip // for output: type integer @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt64> intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private final ISerializerDeserializer<AInt64> intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); private final AMutableInt64 aMutableInt64 = 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/accessors/TemporalYearAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalYearAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalYearAccessor.java index 37ac977..49d841c 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalYearAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalYearAccessor.java @@ -80,8 +80,8 @@ public class TemporalYearAccessor extends AbstractScalarFunctionDynamicDescripto // for output: type integer @SuppressWarnings("unchecked") - private final ISerializerDeserializer<AInt64> intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private final ISerializerDeserializer<AInt64> intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); private final AMutableInt64 aMutableInt64 = 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/common/CreateMBREvalFactory.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/CreateMBREvalFactory.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/CreateMBREvalFactory.java index 0782f06..32196e5 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/CreateMBREvalFactory.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/CreateMBREvalFactory.java @@ -327,10 +327,10 @@ public class CreateMBREvalFactory implements IScalarEvaluatorFactory { } break; default: - throw new TypeMismatchException(BuiltinFunctions.CREATE_MBR, 0, - data0[startOffset0], ATypeTag.SERIALIZED_POINT_TYPE_TAG, - ATypeTag.SERIALIZED_LINE_TYPE_TAG, ATypeTag.SERIALIZED_POLYGON_TYPE_TAG, - ATypeTag.SERIALIZED_CIRCLE_TYPE_TAG, ATypeTag.SERIALIZED_RECTANGLE_TYPE_TAG); + throw new TypeMismatchException(BuiltinFunctions.CREATE_MBR, 0, data0[startOffset0], + ATypeTag.SERIALIZED_POINT_TYPE_TAG, ATypeTag.SERIALIZED_LINE_TYPE_TAG, + ATypeTag.SERIALIZED_POLYGON_TYPE_TAG, ATypeTag.SERIALIZED_CIRCLE_TYPE_TAG, + ATypeTag.SERIALIZED_RECTANGLE_TYPE_TAG); } } else { throw new NotImplementedException(dimension + "D is not supported"); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java index b6e9ae9..dece292 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceCheckEvaluator.java @@ -50,8 +50,8 @@ public class EditDistanceCheckEvaluator extends EditDistanceEvaluator { protected final OrderedListBuilder listBuilder; protected ArrayBackedValueStorage listItemVal; @SuppressWarnings("unchecked") - protected final ISerializerDeserializer<ABoolean> booleanSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + protected final ISerializerDeserializer<ABoolean> booleanSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); public EditDistanceCheckEvaluator(IScalarEvaluatorFactory[] args, IHyracksTaskContext context) throws HyracksDataException { @@ -65,11 +65,11 @@ public class EditDistanceCheckEvaluator extends EditDistanceEvaluator { public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { resultStorage.reset(); firstStringEval.evaluate(tuple, argPtr1); - firstTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); + firstTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); secondStringEval.evaluate(tuple, argPtr2); - secondTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); + secondTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); edThreshEval.evaluate(tuple, argPtrThreshold); if (!checkArgTypes(firstTypeTag, secondTypeTag)) { @@ -92,8 +92,7 @@ public class EditDistanceCheckEvaluator extends EditDistanceEvaluator { } @Override - protected int computeResult(IPointable left, IPointable right, ATypeTag argType) - throws HyracksDataException { + protected int computeResult(IPointable left, IPointable right, ATypeTag argType) throws HyracksDataException { byte[] leftBytes = left.getByteArray(); int leftStartOffset = left.getStartOffset(); byte[] rightBytes = right.getByteArray(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java index 3df6e83..85fd334 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/EditDistanceEvaluator.java @@ -59,8 +59,8 @@ public class EditDistanceEvaluator implements IScalarEvaluator { protected int editDistance = 0; protected final AMutableInt64 aInt64 = new AMutableInt64(-1); @SuppressWarnings("unchecked") - protected final ISerializerDeserializer<AInt64> int64Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + protected final ISerializerDeserializer<AInt64> int64Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); protected ATypeTag itemTypeTag; protected ATypeTag firstTypeTag; @@ -76,11 +76,11 @@ public class EditDistanceEvaluator implements IScalarEvaluator { public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { resultStorage.reset(); firstStringEval.evaluate(tuple, argPtr1); - firstTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); + firstTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); secondStringEval.evaluate(tuple, argPtr2); - secondTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); + secondTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); if (!checkArgTypes(firstTypeTag, secondTypeTag)) { result.set(resultStorage); @@ -96,8 +96,7 @@ public class EditDistanceEvaluator implements IScalarEvaluator { result.set(resultStorage); } - protected int computeResult(IPointable left, IPointable right, ATypeTag argType) - throws HyracksDataException { + protected int computeResult(IPointable left, IPointable right, ATypeTag argType) throws HyracksDataException { byte[] leftBytes = left.getByteArray(); int leftStartOffset = left.getStartOffset(); byte[] rightBytes = right.getByteArray(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/FullTextContainsEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/FullTextContainsEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/FullTextContainsEvaluator.java index b93d613..3bd2587 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/FullTextContainsEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/FullTextContainsEvaluator.java @@ -57,10 +57,10 @@ public class FullTextContainsEvaluator implements IScalarEvaluator { protected final ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); protected final DataOutput out = resultStorage.getDataOutput(); - protected final TaggedValuePointable argLeft = (TaggedValuePointable) TaggedValuePointable.FACTORY - .createPointable(); - protected final TaggedValuePointable argRight = (TaggedValuePointable) TaggedValuePointable.FACTORY - .createPointable(); + protected final TaggedValuePointable argLeft = + (TaggedValuePointable) TaggedValuePointable.FACTORY.createPointable(); + protected final TaggedValuePointable argRight = + (TaggedValuePointable) TaggedValuePointable.FACTORY.createPointable(); protected TaggedValuePointable[] argOptions; protected final IScalarEvaluator evalLeft; protected final IScalarEvaluator evalRight; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityFiltersCache.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityFiltersCache.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityFiltersCache.java index 37b06af..4f5fb69 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityFiltersCache.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityFiltersCache.java @@ -45,8 +45,8 @@ public class SimilarityFiltersCache { bbis.setByteBuffer(ByteBuffer.wrap(similarityNameBytes), startOffset + 1); String similarityName = utf8SerDer.deserialize(dis); similarityNameBytesCached = Arrays.copyOfRange(similarityNameBytes, startOffset, len); - similarityFiltersCached = SimilarityFiltersFactory.getSimilarityFilters(similarityName, - similarityThreshold); + similarityFiltersCached = + SimilarityFiltersFactory.getSimilarityFilters(similarityName, similarityThreshold); } return similarityFiltersCached; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java index 4f7a30f..60b5592 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardCheckEvaluator.java @@ -48,8 +48,8 @@ public class SimilarityJaccardCheckEvaluator extends SimilarityJaccardEvaluator protected OrderedListBuilder listBuilder; protected ArrayBackedValueStorage inputVal; @SuppressWarnings("unchecked") - protected final ISerializerDeserializer<ABoolean> booleanSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + protected final ISerializerDeserializer<ABoolean> booleanSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); protected final AOrderedListType listType = new AOrderedListType(BuiltinType.ANY, "list"); public SimilarityJaccardCheckEvaluator(IScalarEvaluatorFactory[] args, IHyracksTaskContext context) @@ -68,15 +68,15 @@ public class SimilarityJaccardCheckEvaluator extends SimilarityJaccardEvaluator secondOrdListEval.evaluate(tuple, argPtr2); jaccThreshEval.evaluate(tuple, jaccThreshPointable); - firstTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); - secondTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); + firstTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); + secondTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); - firstItemTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset() + 1]); - secondItemTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset() + 1]); + firstItemTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset() + 1]); + secondItemTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset() + 1]); jaccThresh = AFloatSerializerDeserializer.getFloat(jaccThreshPointable.getByteArray(), jaccThreshPointable.getStartOffset() + TYPE_INDICATOR_SIZE); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java index f69248d..1e5ad3c 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/common/SimilarityJaccardEvaluator.java @@ -73,8 +73,8 @@ public class SimilarityJaccardEvaluator implements IScalarEvaluator { protected final AMutableFloat aFloat = new AMutableFloat(0); @SuppressWarnings("unchecked") - protected final ISerializerDeserializer<AFloat> floatSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AFLOAT); + protected final ISerializerDeserializer<AFloat> floatSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AFLOAT); protected ATypeTag firstTypeTag; protected ATypeTag secondTypeTag; @@ -107,15 +107,15 @@ public class SimilarityJaccardEvaluator implements IScalarEvaluator { firstOrdListEval.evaluate(tuple, argPtr1); secondOrdListEval.evaluate(tuple, argPtr2); - firstTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); - secondTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); + firstTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset()]); + secondTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset()]); - firstItemTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset() + 1]); - secondItemTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset() + 1]); + firstItemTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr1.getByteArray()[argPtr1.getStartOffset() + 1]); + secondItemTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(argPtr2.getByteArray()[argPtr2.getStartOffset() + 1]); if (!checkArgTypes(firstTypeTag, secondTypeTag)) { result.set(resultStorage); @@ -229,10 +229,10 @@ public class SimilarityJaccardEvaluator implements IScalarEvaluator { return; } - IBinaryHashFunction putHashFunc = ListItemBinaryHashFunctionFactory.INSTANCE - .createBinaryHashFunction(buildItemTypeTag, ignoreCase); - IBinaryHashFunction getHashFunc = ListItemBinaryHashFunctionFactory.INSTANCE - .createBinaryHashFunction(probeItemTypeTag, ignoreCase); + IBinaryHashFunction putHashFunc = + ListItemBinaryHashFunctionFactory.INSTANCE.createBinaryHashFunction(buildItemTypeTag, ignoreCase); + IBinaryHashFunction getHashFunc = + ListItemBinaryHashFunctionFactory.INSTANCE.createBinaryHashFunction(probeItemTypeTag, ignoreCase); IBinaryComparator cmp = ListItemBinaryComparatorFactory.INSTANCE.createBinaryComparator(buildItemTypeTag, probeItemTypeTag, ignoreCase); hashMap = new BinaryHashMap(hashTableSize, TABLE_FRAME_SIZE, putHashFunc, getHashFunc, cmp); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/AbstractComparisonEvaluator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/AbstractComparisonEvaluator.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/AbstractComparisonEvaluator.java index a1e60a6..620c543 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/AbstractComparisonEvaluator.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/AbstractComparisonEvaluator.java @@ -52,11 +52,11 @@ public abstract class AbstractComparisonEvaluator implements IScalarEvaluator { private ComparisonHelper ch = new ComparisonHelper(); @SuppressWarnings("unchecked") - protected ISerializerDeserializer<ABoolean> serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + protected ISerializerDeserializer<ABoolean> serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); @SuppressWarnings("unchecked") - protected ISerializerDeserializer<ANull> nullSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ANULL); + protected ISerializerDeserializer<ANull> nullSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ANULL); public AbstractComparisonEvaluator(IScalarEvaluatorFactory evalLeftFactory, IScalarEvaluatorFactory evalRightFactory, IHyracksTaskContext context) throws HyracksDataException { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/ComparisonHelper.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/ComparisonHelper.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/ComparisonHelper.java index e4aa4ad..163bd9f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/ComparisonHelper.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/ComparisonHelper.java @@ -51,28 +51,28 @@ public class ComparisonHelper implements Serializable { private static final long serialVersionUID = 1L; static final String COMPARISON = "comparison operations (>, >=, <, and <=)"; - private final IBinaryComparator strBinaryComp = BinaryComparatorFactoryProvider.UTF8STRING_POINTABLE_INSTANCE - .createBinaryComparator(); - private final IBinaryComparator circleBinaryComp = ACirclePartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator durationBinaryComp = ADurationPartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator intervalBinaryComp = AIntervalAscPartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator lineBinaryComparator = ALinePartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator pointBinaryComparator = APointPartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator point3DBinaryComparator = APoint3DPartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator polygonBinaryComparator = APolygonPartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator rectangleBinaryComparator = ARectanglePartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator uuidBinaryComparator = AUUIDPartialBinaryComparatorFactory.INSTANCE - .createBinaryComparator(); - private final IBinaryComparator byteArrayComparator = new PointableBinaryComparatorFactory( - ByteArrayPointable.FACTORY).createBinaryComparator(); + private final IBinaryComparator strBinaryComp = + BinaryComparatorFactoryProvider.UTF8STRING_POINTABLE_INSTANCE.createBinaryComparator(); + private final IBinaryComparator circleBinaryComp = + ACirclePartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator durationBinaryComp = + ADurationPartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator intervalBinaryComp = + AIntervalAscPartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator lineBinaryComparator = + ALinePartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator pointBinaryComparator = + APointPartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator point3DBinaryComparator = + APoint3DPartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator polygonBinaryComparator = + APolygonPartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator rectangleBinaryComparator = + ARectanglePartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator uuidBinaryComparator = + AUUIDPartialBinaryComparatorFactory.INSTANCE.createBinaryComparator(); + private final IBinaryComparator byteArrayComparator = + new PointableBinaryComparatorFactory(ByteArrayPointable.FACTORY).createBinaryComparator(); public int compare(ATypeTag typeTag1, ATypeTag typeTag2, IPointable arg1, IPointable arg2) throws HyracksDataException { @@ -177,7 +177,7 @@ public class ComparisonHelper implements Serializable { private int compareStringWithArg(ATypeTag typeTag2, IPointable arg1, IPointable arg2) throws HyracksDataException { if (typeTag2 == ATypeTag.STRING) { return strBinaryComp.compare(arg1.getByteArray(), arg1.getStartOffset(), arg1.getLength() - 1, - arg2.getByteArray(), arg2.getStartOffset(), arg2.getLength() - 1); + arg2.getByteArray(), arg2.getStartOffset(), arg2.getLength() - 1); } throw new IncompatibleTypeException(COMPARISON, ATypeTag.SERIALIZED_STRING_TYPE_TAG, typeTag2.serialize()); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/DeepEqualAssessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/DeepEqualAssessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/DeepEqualAssessor.java index 1faf75c..21b19aa 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/DeepEqualAssessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/comparisons/DeepEqualAssessor.java @@ -60,9 +60,9 @@ public class DeepEqualAssessor { if (ATypeHierarchy.isSameTypeDomain(leftTypeTag, rightTypeTag, false) && ATypeHierarchy.getTypeDomain(leftTypeTag) == Domain.NUMERIC) { double leftVal = ATypeHierarchy.getDoubleValue(DEEP_EQUAL, 0, leftPointable.getByteArray(), - leftPointable.getStartOffset()); + leftPointable.getStartOffset()); double rightVal = ATypeHierarchy.getDoubleValue(DEEP_EQUAL, 1, rightPointable.getByteArray(), - rightPointable.getStartOffset()); + rightPointable.getStartOffset()); return Math.abs(leftVal - rightVal) < EPSILON; } else { return false; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalConstructorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalConstructorDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalConstructorDescriptor.java index 5b9a36b..9309591 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalConstructorDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalConstructorDescriptor.java @@ -74,8 +74,8 @@ public class AIntervalConstructorDescriptor extends AbstractScalarFunctionDynami private IScalarEvaluator eval1 = args[1].createScalarEvaluator(ctx); private AMutableInterval aInterval = new AMutableInterval(0L, 0L, (byte) 0); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInterval> intervalSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINTERVAL); + private ISerializerDeserializer<AInterval> intervalSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINTERVAL); @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/constructors/AIntervalStartFromDateConstructorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateConstructorDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateConstructorDescriptor.java index a8597c9..0e1942e 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateConstructorDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateConstructorDescriptor.java @@ -84,8 +84,8 @@ public class AIntervalStartFromDateConstructorDescriptor extends AbstractScalarF private AMutableInterval aInterval = new AMutableInterval(0L, 0L, (byte) 0); private AMutableDuration aDuration = new AMutableDuration(0, 0L); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInterval> intervalSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINTERVAL); + private ISerializerDeserializer<AInterval> intervalSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINTERVAL); private final UTF8StringPointable utf8Ptr = new UTF8StringPointable(); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateTimeConstructorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateTimeConstructorDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateTimeConstructorDescriptor.java index 6d56b1b..3e61405 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateTimeConstructorDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromDateTimeConstructorDescriptor.java @@ -82,8 +82,8 @@ public class AIntervalStartFromDateTimeConstructorDescriptor extends AbstractSca private AMutableInterval aInterval = new AMutableInterval(0L, 0L, (byte) 0); private AMutableDuration aDuration = new AMutableDuration(0, 0L); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInterval> intervalSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINTERVAL); + private ISerializerDeserializer<AInterval> intervalSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINTERVAL); private final UTF8StringPointable utf8Ptr = new UTF8StringPointable(); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromTimeConstructorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromTimeConstructorDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromTimeConstructorDescriptor.java index d64e468..fa402bd 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromTimeConstructorDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/AIntervalStartFromTimeConstructorDescriptor.java @@ -82,8 +82,8 @@ public class AIntervalStartFromTimeConstructorDescriptor extends AbstractScalarF private AMutableInterval aInterval = new AMutableInterval(0L, 0L, (byte) 0); private AMutableDuration aDuration = new AMutableDuration(0, 0L); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInterval> intervalSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINTERVAL); + private ISerializerDeserializer<AInterval> intervalSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINTERVAL); private final UTF8StringPointable utf8Ptr = new UTF8StringPointable(); @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/ATimeConstructorDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/ATimeConstructorDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/ATimeConstructorDescriptor.java index 56f6e38..c338a35 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/ATimeConstructorDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/constructors/ATimeConstructorDescriptor.java @@ -70,8 +70,8 @@ public class ATimeConstructorDescriptor extends AbstractScalarFunctionDynamicDes private IScalarEvaluator eval = args[0].createScalarEvaluator(ctx); private AMutableTime aTime = new AMutableTime(0); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ATime> timeSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ATIME); + private ISerializerDeserializer<ATime> timeSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ATIME); private final UTF8StringPointable utf8Ptr = new UTF8StringPointable(); @Override @@ -97,8 +97,8 @@ public class ATimeConstructorDescriptor extends AbstractScalarFunctionDynamicDes ATypeTag.SERIALIZED_POLYGON_TYPE_TAG); } - int chrononTimeInMs = ATimeParserFactory.parseTimePart(serString, startOffset, - stringLength); + int chrononTimeInMs = + ATimeParserFactory.parseTimePart(serString, startOffset, stringLength); if (chrononTimeInMs < 0) { chrononTimeInMs += GregorianCalendarSystem.CHRONON_OF_DAY; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringBoolEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringBoolEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringBoolEval.java index dce2462..9c38fbc 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringBoolEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringBoolEval.java @@ -35,8 +35,8 @@ public abstract class AbstractBinaryStringBoolEval extends AbstractBinaryStringE // For outputting results. @SuppressWarnings({ "rawtypes" }) - private ISerializerDeserializer boolSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private ISerializerDeserializer boolSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); public AbstractBinaryStringBoolEval(IHyracksTaskContext context, IScalarEvaluatorFactory evalLeftFactory, IScalarEvaluatorFactory evalRightFactory, FunctionIdentifier funcID) 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/AbstractBinaryStringIntEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringIntEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringIntEval.java index 5aaee4c..ebe1273 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringIntEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractBinaryStringIntEval.java @@ -36,8 +36,8 @@ public abstract class AbstractBinaryStringIntEval extends AbstractBinaryStringEv // For outputting results. @SuppressWarnings({ "rawtypes" }) - private ISerializerDeserializer intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT32); + private ISerializerDeserializer intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT32); private AMutableInt32 resultValue = new AMutableInt32(0); public AbstractBinaryStringIntEval(IHyracksTaskContext context, IScalarEvaluatorFactory evalLeftFactory, http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractNumericArithmeticEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractNumericArithmeticEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractNumericArithmeticEval.java index 45e9ee1..936415d 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractNumericArithmeticEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractNumericArithmeticEval.java @@ -279,8 +279,7 @@ public abstract class AbstractNumericArithmeticEval extends AbstractScalarFuncti } @SuppressWarnings("unchecked") - private void evaluateTemporalArthmeticOperation(ATypeTag leftType) - throws HyracksDataException { + private void evaluateTemporalArthmeticOperation(ATypeTag leftType) throws HyracksDataException { byte[] bytes1 = argPtr1.getByteArray(); int offset1 = argPtr1.getStartOffset(); ATypeTag rightType = EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(bytes1[offset1]); @@ -318,10 +317,10 @@ public abstract class AbstractNumericArithmeticEval extends AbstractScalarFuncti AYearMonthDurationSerializerDeserializer.getYearMonth(bytes1, offset1 + 1)); break; case DAYTIMEDURATION: - leftChronon = ADayTimeDurationSerializerDeserializer.getDayTime(bytes0, - offset0 + 1); - rightChronon = ADayTimeDurationSerializerDeserializer.getDayTime(bytes1, - offset1 + 1); + leftChronon = + ADayTimeDurationSerializerDeserializer.getDayTime(bytes0, offset0 + 1); + rightChronon = + ADayTimeDurationSerializerDeserializer.getDayTime(bytes1, offset1 + 1); break; default: throw new UnsupportedTypeException(getIdentifier(), bytes1[offset1]); @@ -354,8 +353,8 @@ public abstract class AbstractNumericArithmeticEval extends AbstractScalarFuncti break; case DURATION: dayTime = ADurationSerializerDeserializer.getDayTime(bytes1, offset1 + 1); - yearMonth = ADurationSerializerDeserializer.getYearMonth(bytes1, - offset1 + 1); + yearMonth = + ADurationSerializerDeserializer.getYearMonth(bytes1, offset1 + 1); break; default: throw new IncompatibleTypeException(getIdentifier(), bytes0[offset0], @@ -377,8 +376,8 @@ public abstract class AbstractNumericArithmeticEval extends AbstractScalarFuncti } switch (rightType) { case DURATION: - yearMonth = ADurationSerializerDeserializer.getYearMonth(bytes1, - offset1 + 1); + yearMonth = + ADurationSerializerDeserializer.getYearMonth(bytes1, offset1 + 1); dayTime = ADurationSerializerDeserializer.getDayTime(bytes1, offset1 + 1); break; case YEARMONTHDURATION: @@ -395,8 +394,8 @@ public abstract class AbstractNumericArithmeticEval extends AbstractScalarFuncti } break; case YEARMONTHDURATION: - yearMonth = AYearMonthDurationSerializerDeserializer.getYearMonth(bytes0, - offset0 + 1); + yearMonth = + AYearMonthDurationSerializerDeserializer.getYearMonth(bytes0, offset0 + 1); switch (rightType) { case DATETIME: serde = SerializerDeserializerProvider.INSTANCE @@ -421,8 +420,8 @@ public abstract class AbstractNumericArithmeticEval extends AbstractScalarFuncti dayTime = ADurationSerializerDeserializer.getDayTime(bytes0, offset0 + 1); case DAYTIMEDURATION: if (leftType == ATypeTag.DAYTIMEDURATION) { - dayTime = ADayTimeDurationSerializerDeserializer.getDayTime(bytes0, - offset0 + 1); + dayTime = + ADayTimeDurationSerializerDeserializer.getDayTime(bytes0, offset0 + 1); } switch (rightType) { case DATETIME: http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractQuadStringStringEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractQuadStringStringEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractQuadStringStringEval.java index b607309..1b7c679 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractQuadStringStringEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractQuadStringStringEval.java @@ -59,8 +59,8 @@ public abstract class AbstractQuadStringStringEval implements IScalarEvaluator { private AMutableString resultBuffer = new AMutableString(""); @SuppressWarnings("rawtypes") - private ISerializerDeserializer strSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ASTRING); + private ISerializerDeserializer strSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ASTRING); private final UTF8StringPointable strPtr1st = new UTF8StringPointable(); private final UTF8StringPointable strPtr2nd = 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/AbstractTripleStringBoolEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringBoolEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringBoolEval.java index c7d839e..830f2ff 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringBoolEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringBoolEval.java @@ -34,8 +34,8 @@ import org.apache.hyracks.data.std.primitive.UTF8StringPointable; public abstract class AbstractTripleStringBoolEval extends AbstractTripleStringEval { @SuppressWarnings("rawtypes") - private ISerializerDeserializer boolSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private ISerializerDeserializer boolSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); public AbstractTripleStringBoolEval(IHyracksTaskContext context, IScalarEvaluatorFactory eval0, IScalarEvaluatorFactory eval1, IScalarEvaluatorFactory eval2, FunctionIdentifier funcID) http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringIntEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringIntEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringIntEval.java index 2aa2f1a..7f0076b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringIntEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringIntEval.java @@ -35,8 +35,8 @@ import org.apache.hyracks.data.std.primitive.UTF8StringPointable; public abstract class AbstractTripleStringIntEval extends AbstractTripleStringEval { @SuppressWarnings("rawtypes") - private final ISerializerDeserializer intSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT32); + private final ISerializerDeserializer intSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT32); private final AMutableInt32 resultValue = new AMutableInt32(0); public AbstractTripleStringIntEval(IHyracksTaskContext context, IScalarEvaluatorFactory eval0, http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringStringEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringStringEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringStringEval.java index b7bd056..48ef5f7 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringStringEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractTripleStringStringEval.java @@ -34,8 +34,8 @@ import org.apache.hyracks.data.std.primitive.UTF8StringPointable; public abstract class AbstractTripleStringStringEval extends AbstractTripleStringEval { @SuppressWarnings("rawtypes") - private final ISerializerDeserializer stringSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ASTRING); + private final ISerializerDeserializer stringSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ASTRING); private final AMutableString resultValue = new AMutableString(""); public AbstractTripleStringStringEval(IHyracksTaskContext context, IScalarEvaluatorFactory eval0, http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractUnaryNumericFunctionEval.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractUnaryNumericFunctionEval.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractUnaryNumericFunctionEval.java index c56d58f..06dcc17 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractUnaryNumericFunctionEval.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/AbstractUnaryNumericFunctionEval.java @@ -72,23 +72,23 @@ abstract class AbstractUnaryNumericFunctionEval implements IScalarEvaluator { private final IScalarEvaluator argEval; @SuppressWarnings("rawtypes") - protected ISerializerDeserializer int8Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT8); + protected ISerializerDeserializer int8Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT8); @SuppressWarnings("rawtypes") - protected ISerializerDeserializer int16Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT16); + protected ISerializerDeserializer int16Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT16); @SuppressWarnings("rawtypes") - protected ISerializerDeserializer int32Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT32); + protected ISerializerDeserializer int32Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT32); @SuppressWarnings("rawtypes") - protected ISerializerDeserializer int64Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + protected ISerializerDeserializer int64Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); @SuppressWarnings("rawtypes") - protected ISerializerDeserializer floatSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AFLOAT); + protected ISerializerDeserializer floatSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AFLOAT); @SuppressWarnings("rawtypes") - protected ISerializerDeserializer doubleSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADOUBLE); + protected ISerializerDeserializer doubleSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADOUBLE); // The function identifier, used for error messages. private final FunctionIdentifier funcID; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/BinaryHashMap.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/BinaryHashMap.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/BinaryHashMap.java index 2864473..f0edf5f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/BinaryHashMap.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/BinaryHashMap.java @@ -57,9 +57,8 @@ public class BinaryHashMap { private int nextOff; private int size; - - public BinaryHashMap(int tableSize, int frameSize, IBinaryHashFunction putHashFunc, - IBinaryHashFunction getHashFunc, IBinaryComparator cmp) { + public BinaryHashMap(int tableSize, int frameSize, IBinaryHashFunction putHashFunc, IBinaryHashFunction getHashFunc, + IBinaryComparator cmp) { listHeads = new long[tableSize]; this.frameSize = frameSize; this.putHashFunc = putHashFunc; @@ -198,8 +197,8 @@ public class BinaryHashMap { } public class BinaryHashMapIterator implements Iterator<Pair<BinaryEntry, BinaryEntry>> { - private final Pair<BinaryEntry, BinaryEntry> val = new Pair<BinaryEntry, BinaryEntry>(new BinaryEntry(), - new BinaryEntry()); + private final Pair<BinaryEntry, BinaryEntry> val = + new Pair<BinaryEntry, BinaryEntry>(new BinaryEntry(), new BinaryEntry()); private int listHeadIndex; private ByteBuffer frame; private int frameIndex; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CountHashedGramTokensDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CountHashedGramTokensDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CountHashedGramTokensDescriptor.java index 8998122..dd36671 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CountHashedGramTokensDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CountHashedGramTokensDescriptor.java @@ -58,8 +58,8 @@ public class CountHashedGramTokensDescriptor extends AbstractScalarFunctionDynam @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { ITokenFactory tokenFactory = new HashedUTF8NGramTokenFactory(); - NGramUTF8StringBinaryTokenizer tokenizer = new NGramUTF8StringBinaryTokenizer(3, true, false, true, - tokenFactory); + NGramUTF8StringBinaryTokenizer tokenizer = + new NGramUTF8StringBinaryTokenizer(3, true, false, 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/CreateCircleDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateCircleDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateCircleDescriptor.java index 7dbba41..4866583 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateCircleDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateCircleDescriptor.java @@ -75,8 +75,8 @@ public class CreateCircleDescriptor extends AbstractScalarFunctionDynamicDescrip private AMutablePoint aPoint = new AMutablePoint(0, 0); private AMutableCircle aCircle = new AMutableCircle(null, 0); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ACircle> circleSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ACIRCLE); + private ISerializerDeserializer<ACircle> circleSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ACIRCLE); @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/CreateLineDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateLineDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateLineDescriptor.java index 8165a55..0c8c12f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateLineDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateLineDescriptor.java @@ -75,8 +75,8 @@ public class CreateLineDescriptor extends AbstractScalarFunctionDynamicDescripto private AMutableLine aLine = new AMutableLine(null, null); private AMutablePoint[] aPoint = { new AMutablePoint(0, 0), new AMutablePoint(0, 0) }; @SuppressWarnings("unchecked") - private ISerializerDeserializer<ALine> lineSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ALINE); + private ISerializerDeserializer<ALine> lineSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ALINE); @Override public void evaluate(IFrameTupleReference tuple, IPointable result) throws HyracksDataException { @@ -104,15 +104,15 @@ public class CreateLineDescriptor extends AbstractScalarFunctionDynamicDescripto ADoubleSerializerDeserializer.getDouble(bytes0, offset0 + APointSerializerDeserializer .getCoordinateOffset(Coordinate.X)), - ADoubleSerializerDeserializer.getDouble(bytes0, - offset0 + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); + ADoubleSerializerDeserializer.getDouble(bytes0, offset0 + + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); aPoint[1] .setValue( ADoubleSerializerDeserializer.getDouble(bytes1, offset1 + APointSerializerDeserializer .getCoordinateOffset(Coordinate.X)), - ADoubleSerializerDeserializer.getDouble(bytes1, - offset1 + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); + ADoubleSerializerDeserializer.getDouble(bytes1, offset1 + + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); aLine.setValue(aPoint[0], aPoint[1]); lineSerde.serialize(aLine, out); } 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/CreatePointDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePointDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePointDescriptor.java index 9399f6b..e34091b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePointDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreatePointDescriptor.java @@ -69,8 +69,8 @@ public class CreatePointDescriptor extends AbstractScalarFunctionDynamicDescript private IScalarEvaluator eval1 = args[1].createScalarEvaluator(ctx); private AMutablePoint aPoint = new AMutablePoint(0, 0); @SuppressWarnings("unchecked") - private ISerializerDeserializer<APoint> pointSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.APOINT); + private ISerializerDeserializer<APoint> pointSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.APOINT); @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/CreateRectangleDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateRectangleDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateRectangleDescriptor.java index b51042f..59cc2c1 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateRectangleDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateRectangleDescriptor.java @@ -104,15 +104,15 @@ public class CreateRectangleDescriptor extends AbstractScalarFunctionDynamicDesc ADoubleSerializerDeserializer.getDouble(bytes0, offset0 + APointSerializerDeserializer .getCoordinateOffset(Coordinate.X)), - ADoubleSerializerDeserializer.getDouble(bytes0, - offset0 + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); + ADoubleSerializerDeserializer.getDouble(bytes0, offset0 + + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); aPoint[1] .setValue( ADoubleSerializerDeserializer.getDouble(bytes1, offset1 + APointSerializerDeserializer .getCoordinateOffset(Coordinate.X)), - ADoubleSerializerDeserializer.getDouble(bytes1, - offset1 + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); + ADoubleSerializerDeserializer.getDouble(bytes1, offset1 + + APointSerializerDeserializer.getCoordinateOffset(Coordinate.Y))); if (aPoint[0].getX() > aPoint[1].getX() && aPoint[0].getY() > aPoint[1].getY()) { aRectangle.setValue(aPoint[1], aPoint[0]); } else if (aPoint[0].getX() < aPoint[1].getX() && aPoint[0].getY() < aPoint[1].getY()) { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateUUIDDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateUUIDDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateUUIDDescriptor.java index 829f684..8f43bb9 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateUUIDDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/CreateUUIDDescriptor.java @@ -56,8 +56,8 @@ public class CreateUUIDDescriptor extends AbstractScalarFunctionDynamicDescripto 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/DeepEqualityDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/DeepEqualityDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/DeepEqualityDescriptor.java index 51497ed..79c63e7 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/DeepEqualityDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/DeepEqualityDescriptor.java @@ -76,8 +76,8 @@ public class DeepEqualityDescriptor extends AbstractScalarFunctionDynamicDescrip return new IScalarEvaluatorFactory() { private static final long serialVersionUID = 1L; @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ABoolean> boolSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private final ISerializerDeserializer<ABoolean> boolSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException {
