http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/functions/ExternalFunctionInfo.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/functions/ExternalFunctionInfo.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/functions/ExternalFunctionInfo.java index 0042b26..1bbfc43 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/functions/ExternalFunctionInfo.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/functions/ExternalFunctionInfo.java @@ -35,8 +35,8 @@ public class ExternalFunctionInfo extends FunctionInfo implements IExternalFunct private final FunctionKind kind; private final IAType returnType; - public ExternalFunctionInfo(String namespace, String name, int arity, FunctionKind kind, - List<IAType> argumentTypes, IAType returnType, IResultTypeComputer rtc, String body, String language) { + public ExternalFunctionInfo(String namespace, String name, int arity, FunctionKind kind, List<IAType> argumentTypes, + IAType returnType, IResultTypeComputer rtc, String body, String language) { super(namespace, name, arity, true); this.rtc = rtc; this.argumentTypes = argumentTypes;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/ARecordVisitablePointable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/ARecordVisitablePointable.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/ARecordVisitablePointable.java index 45e56aba..b6ba848 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/ARecordVisitablePointable.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/ARecordVisitablePointable.java @@ -227,8 +227,8 @@ public class ARecordVisitablePointable extends AbstractVisitablePointable { } } else { typeTag = fieldTypes[fieldNumber].getTypeTag(); - fieldValueLength = NonTaggedFormatUtil.getFieldValueLength(b, fieldOffsets[fieldNumber], - typeTag, false); + fieldValueLength = + NonTaggedFormatUtil.getFieldValueLength(b, fieldOffsets[fieldNumber], typeTag, false); } // set field value (including the type tag) int fstart = dataBos.size(); @@ -246,8 +246,8 @@ public class ARecordVisitablePointable extends AbstractVisitablePointable { for (int i = 0; i < numberOfOpenFields; i++) { // set the field name (including a type tag, which is // astring) - int fieldValueLength = NonTaggedFormatUtil.getFieldValueLength(b, fieldOffset, ATypeTag.STRING, - false); + int fieldValueLength = + NonTaggedFormatUtil.getFieldValueLength(b, fieldOffset, ATypeTag.STRING, false); int fnstart = dataBos.size(); dataDos.writeByte(ATypeTag.SERIALIZED_STRING_TYPE_TAG); dataDos.write(b, fieldOffset, fieldValueLength); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/PointableAllocator.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/PointableAllocator.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/PointableAllocator.java index 5f463e6..abd4841 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/PointableAllocator.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/PointableAllocator.java @@ -37,21 +37,21 @@ import org.apache.hyracks.api.exceptions.HyracksDataException; */ public class PointableAllocator { - private IObjectPool<IVisitablePointable, IAType> flatValueAllocator = new ListObjectPool<IVisitablePointable, IAType>( - AFlatValuePointable.FACTORY); - private IObjectPool<IVisitablePointable, IAType> recordValueAllocator = new ListObjectPool<IVisitablePointable, IAType>( - ARecordVisitablePointable.FACTORY); - private IObjectPool<IVisitablePointable, IAType> listValueAllocator = new ListObjectPool<IVisitablePointable, IAType>( - AListVisitablePointable.FACTORY); - private IObjectPool<AOrderedListType, IAType> orederedListTypeAllocator = new ListObjectPool<AOrderedListType, IAType>( - new IObjectFactory<AOrderedListType, IAType>() { + private IObjectPool<IVisitablePointable, IAType> flatValueAllocator = + new ListObjectPool<IVisitablePointable, IAType>(AFlatValuePointable.FACTORY); + private IObjectPool<IVisitablePointable, IAType> recordValueAllocator = + new ListObjectPool<IVisitablePointable, IAType>(ARecordVisitablePointable.FACTORY); + private IObjectPool<IVisitablePointable, IAType> listValueAllocator = + new ListObjectPool<IVisitablePointable, IAType>(AListVisitablePointable.FACTORY); + private IObjectPool<AOrderedListType, IAType> orederedListTypeAllocator = + new ListObjectPool<AOrderedListType, IAType>(new IObjectFactory<AOrderedListType, IAType>() { @Override public AOrderedListType create(IAType type) { return new AOrderedListType(type, type.getTypeName() + "OrderedList"); } }); - private IObjectPool<AOrderedListType, IAType> unorederedListTypeAllocator = new ListObjectPool<AOrderedListType, IAType>( - new IObjectFactory<AOrderedListType, IAType>() { + private IObjectPool<AOrderedListType, IAType> unorederedListTypeAllocator = + new ListObjectPool<AOrderedListType, IAType>(new IObjectFactory<AOrderedListType, IAType>() { @Override public AOrderedListType create(IAType type) { return new AOrderedListType(type, type.getTypeName() + "UnorderedList"); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/base/DefaultOpenFieldType.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/base/DefaultOpenFieldType.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/base/DefaultOpenFieldType.java index 3b8f233..868aab5 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/base/DefaultOpenFieldType.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/base/DefaultOpenFieldType.java @@ -42,12 +42,12 @@ public class DefaultOpenFieldType { } // nested open list type - public static AOrderedListType NESTED_OPEN_AORDERED_LIST_TYPE = new AOrderedListType(BuiltinType.ANY, - "nested-ordered-list"); + public static AOrderedListType NESTED_OPEN_AORDERED_LIST_TYPE = + new AOrderedListType(BuiltinType.ANY, "nested-ordered-list"); // nested open list type - public static AUnorderedListType NESTED_OPEN_AUNORDERED_LIST_TYPE = new AUnorderedListType(BuiltinType.ANY, - "nested-unordered-list"); + public static AUnorderedListType NESTED_OPEN_AUNORDERED_LIST_TYPE = + new AUnorderedListType(BuiltinType.ANY, "nested-unordered-list"); public static IAType getDefaultOpenFieldType(ATypeTag tag) { if (tag.equals(ATypeTag.OBJECT)) http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ACastVisitor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ACastVisitor.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ACastVisitor.java index 72e3072..6eb7d4c 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ACastVisitor.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ACastVisitor.java @@ -112,8 +112,8 @@ public class ACastVisitor implements IVisitablePointableVisitor<Void, Triple<IVi arg.first.set(accessor); return null; } - ATypeTag inputTypeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(accessor.getByteArray()[accessor.getStartOffset()]); + ATypeTag inputTypeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(accessor.getByteArray()[accessor.getStartOffset()]); if (!needPromote(inputTypeTag, reqTypeTag)) { arg.first.set(accessor); } else { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/AListCaster.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/AListCaster.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/AListCaster.java index 9635ac7..ace6769 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/AListCaster.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/AListCaster.java @@ -46,8 +46,8 @@ class AListCaster { // for storing the cast result private final IVisitablePointable itemTempReference = PointableAllocator.allocateUnrestableEmpty(); - private final Triple<IVisitablePointable, IAType, Boolean> itemVisitorArg = new Triple<>(itemTempReference, null, - null); + private final Triple<IVisitablePointable, IAType, Boolean> itemVisitorArg = + new Triple<>(itemTempReference, null, null); private final UnorderedListBuilder unOrderedListBuilder = new UnorderedListBuilder(); private final OrderedListBuilder orderedListBuilder = new OrderedListBuilder(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ARecordCaster.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ARecordCaster.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ARecordCaster.java index 25a2f2b..aa6e26b 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ARecordCaster.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/cast/ARecordCaster.java @@ -73,15 +73,15 @@ class ARecordCaster { private final IVisitablePointable nullTypeTag = PointableAllocator.allocateUnrestableEmpty(); private final IVisitablePointable missingTypeTag = PointableAllocator.allocateUnrestableEmpty(); - private final IBinaryComparator fieldNameComparator = PointableBinaryComparatorFactory - .of(UTF8StringPointable.FACTORY).createBinaryComparator(); + private final IBinaryComparator fieldNameComparator = + PointableBinaryComparatorFactory.of(UTF8StringPointable.FACTORY).createBinaryComparator(); private final ByteArrayAccessibleOutputStream outputBos = new ByteArrayAccessibleOutputStream(); private final DataOutputStream outputDos = new DataOutputStream(outputBos); private final IVisitablePointable fieldTempReference = PointableAllocator.allocateUnrestableEmpty(); - private final Triple<IVisitablePointable, IAType, Boolean> nestedVisitorArg = new Triple<>(fieldTempReference, null, - null); + private final Triple<IVisitablePointable, IAType, Boolean> nestedVisitorArg = + new Triple<>(fieldTempReference, null, null); private int numInputFields = 0; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/AListPointable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/AListPointable.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/AListPointable.java index 114ff2b..7c74a69 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/AListPointable.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/AListPointable.java @@ -189,8 +189,7 @@ public class AListPointable extends AbstractPointable { } } - public void getItemValue(AbstractCollectionType inputType, int index, DataOutput dOut) - throws IOException { + public void getItemValue(AbstractCollectionType inputType, int index, DataOutput dOut) throws IOException { if (getType() != ATypeTag.ANY.serialize()) { dOut.writeByte(getType()); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/ARecordPointable.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/ARecordPointable.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/ARecordPointable.java index af7e29f..77491e8 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/ARecordPointable.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/pointables/nonvisitor/ARecordPointable.java @@ -219,8 +219,7 @@ public class ARecordPointable extends AbstractPointable { // Closed field accessors. // ----------------------- - public void getClosedFieldValue(ARecordType recordType, int fieldId, DataOutput dOut) - throws IOException { + public void getClosedFieldValue(ARecordType recordType, int fieldId, DataOutput dOut) throws IOException { if (isClosedFieldNull(recordType, fieldId)) { dOut.writeByte(ATypeTag.SERIALIZED_NULL_TYPE_TAG); } else if (isClosedFieldMissing(recordType, fieldId)) { @@ -286,8 +285,7 @@ public class ARecordPointable extends AbstractPointable { // Open field accessors. // ----------------------- - public void getOpenFieldValue(ARecordType recordType, int fieldId, DataOutput dOut) - throws IOException { + public void getOpenFieldValue(ARecordType recordType, int fieldId, DataOutput dOut) throws IOException { dOut.write(bytes, getOpenFieldValueOffset(recordType, fieldId), getOpenFieldValueSize(recordType, fieldId)); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/CollectionMemberResultType.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/CollectionMemberResultType.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/CollectionMemberResultType.java index f8f6925..cc2f9b6 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/CollectionMemberResultType.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/CollectionMemberResultType.java @@ -37,8 +37,7 @@ public class CollectionMemberResultType extends AbstractResultTypeComputer { protected void checkArgType(String funcName, int argIndex, IAType type) throws AlgebricksException { ATypeTag actualTypeTag = type.getTypeTag(); if (type.getTypeTag() != ATypeTag.MULTISET && type.getTypeTag() != ATypeTag.ARRAY) { - throw new TypeMismatchException(funcName, argIndex, actualTypeTag, ATypeTag.MULTISET, - ATypeTag.ARRAY); + throw new TypeMismatchException(funcName, argIndex, actualTypeTag, ATypeTag.MULTISET, ATypeTag.ARRAY); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/FieldAccessNestedResultType.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/FieldAccessNestedResultType.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/FieldAccessNestedResultType.java index 21593d9..3eae173 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/FieldAccessNestedResultType.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/FieldAccessNestedResultType.java @@ -59,8 +59,7 @@ public class FieldAccessNestedResultType extends AbstractResultTypeComputer { checkOrderedList(funcName, type); break; default: - throw new TypeMismatchException(funcName, argIndex, actualTypeTag, ATypeTag.STRING, - ATypeTag.ARRAY); + throw new TypeMismatchException(funcName, argIndex, actualTypeTag, ATypeTag.STRING, ATypeTag.ARRAY); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/NonTaggedGetItemResultType.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/NonTaggedGetItemResultType.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/NonTaggedGetItemResultType.java index a81ef34..575ec52 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/NonTaggedGetItemResultType.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/NonTaggedGetItemResultType.java @@ -41,8 +41,7 @@ public class NonTaggedGetItemResultType extends AbstractResultTypeComputer { ATypeTag actualTypeTag = type.getTypeTag(); if (argIndex == 0) { if (type.getTypeTag() != ATypeTag.MULTISET && type.getTypeTag() != ATypeTag.ARRAY) { - throw new TypeMismatchException(funcName, argIndex, actualTypeTag, ATypeTag.STRING, - ATypeTag.ARRAY); + throw new TypeMismatchException(funcName, argIndex, actualTypeTag, ATypeTag.STRING, ATypeTag.ARRAY); } } else { if (!ATypeHierarchy.isCompatible(type.getTypeTag(), ATypeTag.INTEGER)) { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordMergeTypeComputer.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordMergeTypeComputer.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordMergeTypeComputer.java index 5167f30..db4d1c4 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordMergeTypeComputer.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordMergeTypeComputer.java @@ -131,17 +131,17 @@ public class RecordMergeTypeComputer implements IResultTypeComputer { // If a sub-record do merge, else ignore and let the values decide what to do if (fieldType1Copy.getFieldTypes()[i].getTypeTag() == ATypeTag.OBJECT) { IAType[] oldTypes = resultType.getFieldTypes(); - oldTypes[pos] = mergedNestedType(fname, fieldType1Copy.getFieldTypes()[i], - resultType.getFieldTypes()[pos]); + oldTypes[pos] = + mergedNestedType(fname, fieldType1Copy.getFieldTypes()[i], resultType.getFieldTypes()[pos]); resultType = new ARecordType(resultType.getTypeName(), resultType.getFieldNames(), oldTypes, - resultType.isOpen()); + resultType.isOpen()); } } else { - IAType[] combinedFieldTypes = ArrayUtils.addAll(resultType.getFieldTypes().clone(), - fieldType1Copy.getFieldTypes()[i]); + IAType[] combinedFieldTypes = + ArrayUtils.addAll(resultType.getFieldTypes().clone(), fieldType1Copy.getFieldTypes()[i]); resultType = new ARecordType(resultType.getTypeName(), - ArrayUtils.addAll(resultType.getFieldNames(), fieldType1Copy.getFieldNames()[i]), - combinedFieldTypes, resultType.isOpen()); + ArrayUtils.addAll(resultType.getFieldNames(), fieldType1Copy.getFieldNames()[i]), + combinedFieldTypes, resultType.isOpen()); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordRemoveFieldsTypeComputer.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordRemoveFieldsTypeComputer.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordRemoveFieldsTypeComputer.java index 3bd64d6..e0b10d1 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordRemoveFieldsTypeComputer.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/RecordRemoveFieldsTypeComputer.java @@ -128,8 +128,7 @@ public class RecordRemoveFieldsTypeComputer implements IResultTypeComputer { } private void computeTypeFromNonConstantExpression(String funcName, ILogicalExpression expression, - Set<String> fieldNameSet, - List<List<String>> pathList) throws AlgebricksException { + Set<String> fieldNameSet, List<List<String>> pathList) throws AlgebricksException { AbstractFunctionCallExpression funcExp = (AbstractFunctionCallExpression) expression; List<Mutable<ILogicalExpression>> args = funcExp.getArguments(); @@ -188,8 +187,8 @@ public class RecordRemoveFieldsTypeComputer implements IResultTypeComputer { private boolean setFieldNameSet(ILogicalExpression expr, Set<String> fieldNameSet) { if (expr.getExpressionTag() == LogicalExpressionTag.CONSTANT) { - AOrderedList orderedList = (AOrderedList) (((AsterixConstantValue) ((ConstantExpression) expr).getValue()) - .getObject()); + AOrderedList orderedList = + (AOrderedList) (((AsterixConstantValue) ((ConstantExpression) expr).getValue()).getObject()); for (int i = 0; i < orderedList.size(); i++) { AString as = (AString) orderedList.getItem(i); fieldNameSet.add(as.getStringValue()); @@ -320,8 +319,7 @@ public class RecordRemoveFieldsTypeComputer implements IResultTypeComputer { destFieldTypes.toArray(new IAType[n]), isOpen); } - private static ARecordType getRecordTypeFromType(String funcName, IAType type0) - throws AlgebricksException { + private static ARecordType getRecordTypeFromType(String funcName, IAType type0) throws AlgebricksException { switch (type0.getTypeTag()) { case OBJECT: return (ARecordType) type0; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/SubsetCollectionTypeComputer.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/SubsetCollectionTypeComputer.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/SubsetCollectionTypeComputer.java index 7867cf6..0ab49d0 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/SubsetCollectionTypeComputer.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/typecomputer/impl/SubsetCollectionTypeComputer.java @@ -55,8 +55,7 @@ public class SubsetCollectionTypeComputer implements IResultTypeComputer { case UNION: { AUnionType ut = (AUnionType) t; if (!ut.isUnknownableType()) { - throw new TypeMismatchException(funcName, 0, actualTypeTag, ATypeTag.MULTISET, - ATypeTag.ARRAY); + throw new TypeMismatchException(funcName, 0, actualTypeTag, ATypeTag.MULTISET, ATypeTag.ARRAY); } IAType t2 = ut.getActualType(); ATypeTag tag2 = t2.getTypeTag(); @@ -64,14 +63,12 @@ public class SubsetCollectionTypeComputer implements IResultTypeComputer { AbstractCollectionType act = (AbstractCollectionType) t2; return act.getItemType(); } - throw new TypeMismatchException(funcName, 0, actualTypeTag, ATypeTag.MULTISET, - ATypeTag.ARRAY); + throw new TypeMismatchException(funcName, 0, actualTypeTag, ATypeTag.MULTISET, ATypeTag.ARRAY); } case ANY: return BuiltinType.ANY; default: - throw new TypeMismatchException(funcName, 0, actualTypeTag, ATypeTag.MULTISET, - ATypeTag.ARRAY); + throw new TypeMismatchException(funcName, 0, actualTypeTag, ATypeTag.MULTISET, ATypeTag.ARRAY); } } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AOrderedListType.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AOrderedListType.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AOrderedListType.java index 1c1bdbc..7cb383f 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AOrderedListType.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AOrderedListType.java @@ -77,7 +77,7 @@ public class AOrderedListType extends AbstractCollectionType { } @Override - public ObjectNode toJSON() { + public ObjectNode toJSON() { ObjectMapper om = new ObjectMapper(); ObjectNode type = om.createObjectNode(); type.put("type", AOrderedListType.class.getName()); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/ATypeTag.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/ATypeTag.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/ATypeTag.java index 6889934..825ed70 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/ATypeTag.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/ATypeTag.java @@ -130,8 +130,7 @@ public enum ATypeTag implements IEnumSerializer { } public boolean isDerivedType() { - return this == ATypeTag.OBJECT || this == ATypeTag.ARRAY || this == ATypeTag.MULTISET - || this == ATypeTag.UNION; + return this == ATypeTag.OBJECT || this == ATypeTag.ARRAY || this == ATypeTag.MULTISET || this == ATypeTag.UNION; } @Override http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnionType.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnionType.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnionType.java index ace3b6c..007f072 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnionType.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnionType.java @@ -196,7 +196,7 @@ public class AUnionType extends AbstractComplexType { } @Override - public ObjectNode toJSON() { + public ObjectNode toJSON() { ObjectMapper om = new ObjectMapper(); ObjectNode type = om.createObjectNode(); type.put("type", AUnionType.class.getName()); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnorderedListType.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnorderedListType.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnorderedListType.java index 6de918a..8d088f7 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnorderedListType.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/AUnorderedListType.java @@ -27,7 +27,7 @@ public class AUnorderedListType extends AbstractCollectionType { private static final long serialVersionUID = 1L; - public static final AUnorderedListType FULLY_OPEN_UNORDEREDLIST_TYPE = new AUnorderedListType(null,""); + public static final AUnorderedListType FULLY_OPEN_UNORDEREDLIST_TYPE = new AUnorderedListType(null, ""); /** * @param itemType @@ -77,7 +77,7 @@ public class AUnorderedListType extends AbstractCollectionType { } @Override - public ObjectNode toJSON() { + public ObjectNode toJSON() { ObjectMapper om = new ObjectMapper(); ObjectNode type = om.createObjectNode(); type.put("type", AUnorderedListType.class.getName()); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/EnumDeserializer.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/EnumDeserializer.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/EnumDeserializer.java index 8ec8989..05f265c 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/EnumDeserializer.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/EnumDeserializer.java @@ -23,8 +23,8 @@ import java.util.Map; public class EnumDeserializer<E extends Enum<E> & IEnumSerializer> { - public static final EnumDeserializer<ATypeTag> ATYPETAGDESERIALIZER = new EnumDeserializer<ATypeTag>( - ATypeTag.class); + public static final EnumDeserializer<ATypeTag> ATYPETAGDESERIALIZER = + new EnumDeserializer<ATypeTag>(ATypeTag.class); private Map<Byte, E> enumvalMap = new HashMap<Byte, E>(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/runtime/RuntimeRecordTypeInfo.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/runtime/RuntimeRecordTypeInfo.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/runtime/RuntimeRecordTypeInfo.java index a34bd40..55108a1 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/runtime/RuntimeRecordTypeInfo.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/types/runtime/RuntimeRecordTypeInfo.java @@ -53,10 +53,10 @@ public class RuntimeRecordTypeInfo { private ARecordType cachedRecType = null; public RuntimeRecordTypeInfo() { - fieldNameComparator = new PointableBinaryComparatorFactory(UTF8StringPointable.FACTORY) - .createBinaryComparator(); - fieldNameHashFunction = new PointableBinaryHashFunctionFactory(UTF8StringPointable.FACTORY) - .createBinaryHashFunction(); + fieldNameComparator = + new PointableBinaryComparatorFactory(UTF8StringPointable.FACTORY).createBinaryComparator(); + fieldNameHashFunction = + new PointableBinaryHashFunctionFactory(UTF8StringPointable.FACTORY).createBinaryHashFunction(); writer = new UTF8StringWriter(); } @@ -88,8 +88,8 @@ public class RuntimeRecordTypeInfo { serializedFieldNameOffsets[i] = baaos.size(); writer.writeUTF8(fieldNames[i], dos); length = baaos.size() - serializedFieldNameOffsets[i]; - hashCodeIndexPairs[i] = fieldNameHashFunction.hash(baaos.getByteArray(), - serializedFieldNameOffsets[i], length); + hashCodeIndexPairs[i] = + fieldNameHashFunction.hash(baaos.getByteArray(), serializedFieldNameOffsets[i], length); hashCodeIndexPairs[i] = hashCodeIndexPairs[i] << 32; hashCodeIndexPairs[i] = hashCodeIndexPairs[i] | i; } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/utils/RecordUtil.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/utils/RecordUtil.java b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/utils/RecordUtil.java index e4a057f..ec1c7cb 100644 --- a/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/utils/RecordUtil.java +++ b/asterixdb/asterix-om/src/main/java/org/apache/asterix/om/utils/RecordUtil.java @@ -73,7 +73,6 @@ public class RecordUtil { */ public static int computeNullBitmapSize(ARecordType recordType) { return NonTaggedFormatUtil.hasOptionalField(recordType) - ? (int) Math.ceil(recordType.getFieldNames().length / 4.0) - : 0; + ? (int) Math.ceil(recordType.getFieldNames().length / 4.0) : 0; } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SerializerDeserializerTestUtils.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SerializerDeserializerTestUtils.java b/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SerializerDeserializerTestUtils.java index 4d41092..68923a1 100644 --- a/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SerializerDeserializerTestUtils.java +++ b/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SerializerDeserializerTestUtils.java @@ -64,19 +64,19 @@ public class SerializerDeserializerTestUtils { ARecord addr12 = new ARecord(addrRecordType, new IAObject[] { new AString("210 University Drive"), new AString("Philadelphia"), new AString("PA"), new AInt16((short) 10086), new AInterval(100, 300, (byte) 0) }); - ARecord addr21 = new ARecord(addrRecordType, - new IAObject[] { new AString("1 College Street"), new AString("Seattle"), new AString("WA"), - new AInt16((short) 20012), new AInterval(400, 500, (byte) 0) }); - ARecord addr22 = new ARecord(addrRecordType, - new IAObject[] { new AString("20 Lindsay Avenue"), new AString("Columbus"), new AString("OH"), - new AInt16((short) 30120), new AInterval(600, 900, (byte) 0) }); - ARecord addr31 = new ARecord(addrRecordType, - new IAObject[] { new AString("200 14th Avenue"), new AString("Long Island"), new AString("NY"), - new AInt16((short) 95011), new AInterval(12000, 14000, (byte) 0) }); + ARecord addr21 = + new ARecord(addrRecordType, new IAObject[] { new AString("1 College Street"), new AString("Seattle"), + new AString("WA"), new AInt16((short) 20012), new AInterval(400, 500, (byte) 0) }); + ARecord addr22 = + new ARecord(addrRecordType, new IAObject[] { new AString("20 Lindsay Avenue"), new AString("Columbus"), + new AString("OH"), new AInt16((short) 30120), new AInterval(600, 900, (byte) 0) }); + ARecord addr31 = + new ARecord(addrRecordType, new IAObject[] { new AString("200 14th Avenue"), new AString("Long Island"), + new AString("NY"), new AInt16((short) 95011), new AInterval(12000, 14000, (byte) 0) }); // With nested open field addr31. - ARecord addr32 = new ARecord(addrRecordType, - new IAObject[] { new AString("51 8th Street"), new AString("Orlando"), new AString("FL"), - new AInt16((short) 49045), new AInterval(190000, 200000, (byte) 0) }); + ARecord addr32 = + new ARecord(addrRecordType, new IAObject[] { new AString("51 8th Street"), new AString("Orlando"), + new AString("FL"), new AInt16((short) 49045), new AInterval(190000, 200000, (byte) 0) }); ARecord record1 = new ARecord(employeeType, new IAObject[] { new AInt64(0L), new AString("Tom"), new AOrderedList(addrListType, Arrays.asList(new IAObject[] { addr11, addr12 })) }); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SimpleSerializerDeserializerTest.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SimpleSerializerDeserializerTest.java b/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SimpleSerializerDeserializerTest.java index 8a5270f..a661f64 100644 --- a/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SimpleSerializerDeserializerTest.java +++ b/asterixdb/asterix-om/src/test/java/org/apache/asterix/dataflow/data/nontagged/serde/SimpleSerializerDeserializerTest.java @@ -32,8 +32,8 @@ public class SimpleSerializerDeserializerTest { @Test public void test() { Reflections reflections = new Reflections("org.apache.asterix.dataflow.data.nontagged.serde"); - Set<Class<? extends ISerializerDeserializer>> allClasses = reflections - .getSubTypesOf(ISerializerDeserializer.class); + Set<Class<? extends ISerializerDeserializer>> allClasses = + reflections.getSubTypesOf(ISerializerDeserializer.class); for (Class<? extends ISerializerDeserializer> cl : allClasses) { String className = cl.getName(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/logging/RemoteLogsNotifier.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/logging/RemoteLogsNotifier.java b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/logging/RemoteLogsNotifier.java index d63496f..366abce 100644 --- a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/logging/RemoteLogsNotifier.java +++ b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/logging/RemoteLogsNotifier.java @@ -66,8 +66,8 @@ class RemoteLogsNotifier implements Runnable { case LogType.ABORT: // send ACK to requester logRecord.getReplicationWorker().getChannel().socket().getOutputStream() - .write((nodeId + ReplicationProtocol.LOG_REPLICATION_ACK + logRecord.getTxnId() + System - .lineSeparator()).getBytes()); + .write((nodeId + ReplicationProtocol.LOG_REPLICATION_ACK + logRecord.getTxnId() + + System.lineSeparator()).getBytes()); break; case LogType.FLUSH: checkpointReplicaIndexes(logRecord, logRecord.getDatasetId()); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/management/LogReplicationManager.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/management/LogReplicationManager.java b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/management/LogReplicationManager.java index b28c2f7..7a9d75f 100644 --- a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/management/LogReplicationManager.java +++ b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/management/LogReplicationManager.java @@ -217,9 +217,8 @@ public class LogReplicationManager { } LOGGER.error("Replica failed", e); failedSockets.add(replicaSocket); - Optional<ReplicationDestination> socketDest = - destinations.entrySet().stream().filter(entry -> entry.getValue().equals(replicaSocket)) - .map(Map.Entry::getKey).findFirst(); + Optional<ReplicationDestination> socketDest = destinations.entrySet().stream() + .filter(entry -> entry.getValue().equals(replicaSocket)).map(Map.Entry::getKey).findFirst(); socketDest.ifPresent(dest -> replicationManager.notifyFailure(dest, e)); } @@ -236,8 +235,8 @@ public class LogReplicationManager { public void run() { Thread.currentThread().setName("TxnAckListener (" + dest + ")"); LOGGER.info("Started listening on socket: {}", dest); - try (BufferedReader incomingResponse = new BufferedReader( - new InputStreamReader(replicaSocket.socket().getInputStream()))) { + try (BufferedReader incomingResponse = + new BufferedReader(new InputStreamReader(replicaSocket.socket().getInputStream()))) { while (true) { final String response = incomingResponse.readLine(); if (response == null) { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/messaging/ReplicateFileTask.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/messaging/ReplicateFileTask.java b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/messaging/ReplicateFileTask.java index 99c7256..ca0fcca 100644 --- a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/messaging/ReplicateFileTask.java +++ b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/messaging/ReplicateFileTask.java @@ -74,8 +74,8 @@ public class ReplicateFileTask implements IReplicaTask { // receive actual file final Path filePath = Paths.get(resourceDir.toString(), localPath.getFile().getName()); Files.createFile(filePath); - try (RandomAccessFile fileOutputStream = new RandomAccessFile(filePath.toFile(), - "rw"); FileChannel fileChannel = fileOutputStream.getChannel()) { + try (RandomAccessFile fileOutputStream = new RandomAccessFile(filePath.toFile(), "rw"); + FileChannel fileChannel = fileOutputStream.getChannel()) { fileOutputStream.setLength(size); NetworkingUtil.downloadFile(fileChannel, worker.getChannel()); fileChannel.force(true); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/sync/FileSynchronizer.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/sync/FileSynchronizer.java b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/sync/FileSynchronizer.java index e1649b3..cc0f7b4 100644 --- a/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/sync/FileSynchronizer.java +++ b/asterixdb/asterix-replication/src/main/java/org/apache/asterix/replication/sync/FileSynchronizer.java @@ -55,8 +55,8 @@ public class FileSynchronizer { ReplicateFileTask task = new ReplicateFileTask(file, filePath.getFile().length(), metadata); ReplicationProtocol.sendTo(replica, task); // send the file itself - try (RandomAccessFile fromFile = new RandomAccessFile(filePath.getFile(), - "r"); FileChannel fileChannel = fromFile.getChannel()) { + try (RandomAccessFile fromFile = new RandomAccessFile(filePath.getFile(), "r"); + FileChannel fileChannel = fromFile.getChannel()) { NetworkingUtil.sendFile(fileChannel, channel); } ReplicationProtocol.waitForAck(replica); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/scalar/AbstractScalarAggregateDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/scalar/AbstractScalarAggregateDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/scalar/AbstractScalarAggregateDescriptor.java index 643098f..e929f0f 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/scalar/AbstractScalarAggregateDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/scalar/AbstractScalarAggregateDescriptor.java @@ -55,8 +55,8 @@ public abstract class AbstractScalarAggregateDescriptor extends AbstractScalarFu @Override public IScalarEvaluator createScalarEvaluator(IHyracksTaskContext ctx) throws HyracksDataException { // Use ScanCollection to iterate over list items. - ScanCollectionUnnestingFunctionFactory scanCollectionFactory = new ScanCollectionUnnestingFunctionFactory( - args[0]); + ScanCollectionUnnestingFunctionFactory scanCollectionFactory = + new ScanCollectionUnnestingFunctionFactory(args[0]); return new GenericScalarAggregateFunction(aggFuncFactory.createAggregateEvaluator(ctx), scanCollectionFactory, ctx); } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableAvgAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableAvgAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableAvgAggregateFunction.java index 7fc264b..db12b85 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableAvgAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableAvgAggregateFunction.java @@ -81,14 +81,14 @@ public abstract class AbstractSerializableAvgAggregateFunction implements ISeria private ClosedRecordConstructorEval recordEval; @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADouble> doubleSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADOUBLE); + private ISerializerDeserializer<ADouble> doubleSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADOUBLE); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInt64> longSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private ISerializerDeserializer<AInt64> longSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ANull> nullSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ANULL); + private ISerializerDeserializer<ANull> nullSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ANULL); public AbstractSerializableAvgAggregateFunction(IScalarEvaluatorFactory[] args, 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/aggregates/serializable/std/AbstractSerializableCountAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableCountAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableCountAggregateFunction.java index b010735..9a7cc98 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableCountAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/AbstractSerializableCountAggregateFunction.java @@ -47,11 +47,11 @@ public abstract class AbstractSerializableCountAggregateFunction implements ISer private AMutableInt64 result = new AMutableInt64(-1); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInt64> int64Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private ISerializerDeserializer<AInt64> int64Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ANull> nullSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ANULL); + private ISerializerDeserializer<ANull> nullSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ANULL); private IPointable inputVal = new VoidPointable(); private IScalarEvaluator eval; @@ -75,8 +75,8 @@ public abstract class AbstractSerializableCountAggregateFunction implements ISer boolean metNull = BufferSerDeUtil.getBoolean(state, start); long cnt = BufferSerDeUtil.getLong(state, start + 1); eval.evaluate(tuple, inputVal); - ATypeTag typeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(inputVal.getByteArray()[inputVal.getStartOffset()]); + ATypeTag typeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(inputVal.getByteArray()[inputVal.getStartOffset()]); if (typeTag == ATypeTag.MISSING || typeTag == ATypeTag.NULL) { processNull(state, start); } else { http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSqlSumAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSqlSumAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSqlSumAggregateFunction.java index 4c42f98..c42c350 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSqlSumAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSqlSumAggregateFunction.java @@ -50,8 +50,7 @@ public class SerializableSqlSumAggregateFunction extends AbstractSerializableSum // but if all input value are system null, then we should return // null in finish(). if (isLocalAgg) { - throw new UnsupportedItemTypeException(BuiltinFunctions.SQL_SUM, - ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); + throw new UnsupportedItemTypeException(BuiltinFunctions.SQL_SUM, ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSumAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSumAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSumAggregateFunction.java index c4f85a2..60e34fa 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSumAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/serializable/std/SerializableSumAggregateFunction.java @@ -58,8 +58,7 @@ public class SerializableSumAggregateFunction extends AbstractSerializableSumAgg // but if all input value are system null, then we should return // null in finish(). if (isLocalAgg) { - throw new UnsupportedItemTypeException(BuiltinFunctions.SUM, - ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); + throw new UnsupportedItemTypeException(BuiltinFunctions.SUM, ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractAvgAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractAvgAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractAvgAggregateFunction.java index 48eb1de..bf45c0b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractAvgAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractAvgAggregateFunction.java @@ -84,14 +84,14 @@ public abstract class AbstractAvgAggregateFunction implements IAggregateEvaluato private ClosedRecordConstructorEval recordEval; @SuppressWarnings("unchecked") - private ISerializerDeserializer<ADouble> doubleSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADOUBLE); + private ISerializerDeserializer<ADouble> doubleSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADOUBLE); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInt64> longSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private ISerializerDeserializer<AInt64> longSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); @SuppressWarnings("unchecked") - private ISerializerDeserializer<ANull> nullSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ANULL); + private ISerializerDeserializer<ANull> nullSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ANULL); public AbstractAvgAggregateFunction(IScalarEvaluatorFactory[] args, 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/aggregates/std/AbstractCountAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractCountAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractCountAggregateFunction.java index bd0243b..38e8d8b 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractCountAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractCountAggregateFunction.java @@ -43,8 +43,8 @@ import org.apache.hyracks.dataflow.common.data.accessors.IFrameTupleReference; public abstract class AbstractCountAggregateFunction implements IAggregateEvaluator { private AMutableInt64 result = new AMutableInt64(-1); @SuppressWarnings("unchecked") - private ISerializerDeserializer<AInt64> int64Serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.AINT64); + private ISerializerDeserializer<AInt64> int64Serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.AINT64); private IPointable inputVal = new VoidPointable(); private IScalarEvaluator eval; protected long cnt; @@ -64,8 +64,8 @@ public abstract class AbstractCountAggregateFunction implements IAggregateEvalua @Override public void step(IFrameTupleReference tuple) throws HyracksDataException { eval.evaluate(tuple, inputVal); - ATypeTag typeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(inputVal.getByteArray()[inputVal.getStartOffset()]); + ATypeTag typeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(inputVal.getByteArray()[inputVal.getStartOffset()]); // Ignore SYSTEM_NULL. if (typeTag == ATypeTag.NULL || typeTag == ATypeTag.MISSING) { processNull(); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractMinMaxAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractMinMaxAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractMinMaxAggregateFunction.java index b7c70aa..32c40e6 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractMinMaxAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/AbstractMinMaxAggregateFunction.java @@ -68,8 +68,8 @@ public abstract class AbstractMinMaxAggregateFunction implements IAggregateEvalu return; } eval.evaluate(tuple, inputVal); - ATypeTag typeTag = EnumDeserializer.ATYPETAGDESERIALIZER - .deserialize(inputVal.getByteArray()[inputVal.getStartOffset()]); + ATypeTag typeTag = + EnumDeserializer.ATYPETAGDESERIALIZER.deserialize(inputVal.getByteArray()[inputVal.getStartOffset()]); if (typeTag == ATypeTag.MISSING || typeTag == ATypeTag.NULL) { processNull(); return; @@ -81,8 +81,8 @@ public abstract class AbstractMinMaxAggregateFunction implements IAggregateEvalu // First value encountered. Set type, comparator, and initial value. aggType = typeTag; // Set comparator. - IBinaryComparatorFactory cmpFactory = BinaryComparatorFactoryProvider.INSTANCE - .getBinaryComparatorFactory(aggType, isMin); + IBinaryComparatorFactory cmpFactory = + BinaryComparatorFactoryProvider.INSTANCE.getBinaryComparatorFactory(aggType, isMin); cmp = cmpFactory.createBinaryComparator(); // Initialize min value. outputVal.assign(inputVal); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SqlSumAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SqlSumAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SqlSumAggregateFunction.java index 09e8822..663ed69 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SqlSumAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SqlSumAggregateFunction.java @@ -49,8 +49,7 @@ public class SqlSumAggregateFunction extends AbstractSumAggregateFunction { // but if all input value are system null, then we should return // null in finish(). if (isLocalAgg) { - throw new UnsupportedItemTypeException(BuiltinFunctions.SQL_SUM, - ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); + throw new UnsupportedItemTypeException(BuiltinFunctions.SQL_SUM, ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SumAggregateFunction.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SumAggregateFunction.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SumAggregateFunction.java index d406846..2b3beef 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SumAggregateFunction.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/std/SumAggregateFunction.java @@ -55,8 +55,7 @@ public class SumAggregateFunction extends AbstractSumAggregateFunction { // but if all input value are system null, then we should return // null in finish(). if (isLocalAgg) { - throw new UnsupportedItemTypeException(BuiltinFunctions.SUM, - ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); + throw new UnsupportedItemTypeException(BuiltinFunctions.SUM, ATypeTag.SERIALIZED_SYSTEM_NULL_TYPE_TAG); } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/EmptyStreamAggregateDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/EmptyStreamAggregateDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/EmptyStreamAggregateDescriptor.java index 66d81f6..dc2b355 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/EmptyStreamAggregateDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/EmptyStreamAggregateDescriptor.java @@ -62,8 +62,8 @@ public class EmptyStreamAggregateDescriptor extends AbstractAggregateFunctionDyn private ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); @SuppressWarnings("rawtypes") - private ISerializerDeserializer serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private ISerializerDeserializer serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); boolean res = true; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/NonEmptyStreamAggregateDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/NonEmptyStreamAggregateDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/NonEmptyStreamAggregateDescriptor.java index 2c8f409..e9330d3 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/NonEmptyStreamAggregateDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/aggregates/stream/NonEmptyStreamAggregateDescriptor.java @@ -60,8 +60,8 @@ public class NonEmptyStreamAggregateDescriptor extends AbstractAggregateFunction private ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); @SuppressWarnings("rawtypes") - private ISerializerDeserializer serde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ABOOLEAN); + private ISerializerDeserializer serde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ABOOLEAN); boolean res = false; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleCenterAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleCenterAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleCenterAccessor.java index 857ac2e..e10bd07 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleCenterAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleCenterAccessor.java @@ -72,8 +72,8 @@ public class CircleCenterAccessor extends AbstractScalarFunctionDynamicDescripto private final IScalarEvaluator eval = args[0].createScalarEvaluator(ctx); private final AMutablePoint aPoint = new AMutablePoint(0, 0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<APoint> pointSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.APOINT); + private final 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/accessors/CircleRadiusAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleRadiusAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleRadiusAccessor.java index fcc0b0a..2fc24e4 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleRadiusAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/CircleRadiusAccessor.java @@ -70,8 +70,8 @@ public class CircleRadiusAccessor extends AbstractScalarFunctionDynamicDescripto private final IScalarEvaluator eval = args[0].createScalarEvaluator(ctx); private final AMutableDouble aDouble = new AMutableDouble(0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ADouble> doubleSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADOUBLE); + private final ISerializerDeserializer<ADouble> doubleSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADOUBLE); @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/accessors/LineRectanglePolygonAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/LineRectanglePolygonAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/LineRectanglePolygonAccessor.java index 7330cc1..66de80a 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/LineRectanglePolygonAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/LineRectanglePolygonAccessor.java @@ -80,8 +80,8 @@ public class LineRectanglePolygonAccessor extends AbstractScalarFunctionDynamicD private final AOrderedListType pointListType = new AOrderedListType(BuiltinType.APOINT, null); private final AMutablePoint aPoint = new AMutablePoint(0, 0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<APoint> pointSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.APOINT); + private final 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/accessors/PointXCoordinateAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointXCoordinateAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointXCoordinateAccessor.java index a90e6c63..0aa38f3 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointXCoordinateAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointXCoordinateAccessor.java @@ -70,8 +70,8 @@ public class PointXCoordinateAccessor extends AbstractScalarFunctionDynamicDescr private final IScalarEvaluator eval = args[0].createScalarEvaluator(ctx); private final AMutableDouble aDouble = new AMutableDouble(0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ADouble> doubleSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADOUBLE); + private final ISerializerDeserializer<ADouble> doubleSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADOUBLE); @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/accessors/PointYCoordinateAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointYCoordinateAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointYCoordinateAccessor.java index 5a0840c..cfaa5d5 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointYCoordinateAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/PointYCoordinateAccessor.java @@ -74,8 +74,8 @@ public class PointYCoordinateAccessor extends AbstractScalarFunctionDynamicDescr private final IScalarEvaluator eval = args[0].createScalarEvaluator(ctx); private final AMutableDouble aDouble = new AMutableDouble(0); @SuppressWarnings("unchecked") - private final ISerializerDeserializer<ADouble> doubleSerde = SerializerDeserializerProvider.INSTANCE - .getSerializerDeserializer(BuiltinType.ADOUBLE); + private final ISerializerDeserializer<ADouble> doubleSerde = + SerializerDeserializerProvider.INSTANCE.getSerializerDeserializer(BuiltinType.ADOUBLE); @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/accessors/TemporalDayAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalDayAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalDayAccessor.java index c19acde..4e62659 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalDayAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalDayAccessor.java @@ -79,8 +79,8 @@ public class TemporalDayAccessor extends AbstractScalarFunctionDynamicDescriptor // 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/TemporalHourAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalHourAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalHourAccessor.java index 08bb71d..7ba57f9 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalHourAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalHourAccessor.java @@ -81,8 +81,8 @@ public class TemporalHourAccessor 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/accessors/TemporalIntervalEndAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndAccessor.java index d3ac99b..0d5d01c 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndAccessor.java @@ -75,16 +75,16 @@ public class TemporalIntervalEndAccessor extends AbstractScalarFunctionDynamicDe // 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,8 +96,8 @@ public class TemporalIntervalEndAccessor extends AbstractScalarFunctionDynamicDe resultStorage.reset(); try { if (bytes[startOffset] == ATypeTag.SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); long endTime = AIntervalSerializerDeserializer.getIntervalEnd(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_DATE_TYPE_TAG) { aDate.setValue((int) (endTime)); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDateAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDateAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDateAccessor.java index 5c888eb..b83cbd1 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDateAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDateAccessor.java @@ -71,8 +71,8 @@ public class TemporalIntervalEndDateAccessor extends AbstractScalarFunctionDynam // 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 @@ -84,8 +84,8 @@ public class TemporalIntervalEndDateAccessor extends AbstractScalarFunctionDynam resultStorage.reset(); try { if (bytes[startOffset] == ATypeTag.SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); long endTime = AIntervalSerializerDeserializer.getIntervalEnd(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_DATE_TYPE_TAG) { aDate.setValue((int) (endTime)); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDatetimeAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDatetimeAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDatetimeAccessor.java index 66e6e02..c806db1 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDatetimeAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndDatetimeAccessor.java @@ -86,8 +86,8 @@ public class TemporalIntervalEndDatetimeAccessor extends AbstractScalarFunctionD resultStorage.reset(); try { if (bytes[startOffset] == ATypeTag.SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); long endTime = AIntervalSerializerDeserializer.getIntervalEnd(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_DATETIME_TYPE_TAG) { aDateTime.setValue(endTime); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/cb9ca975/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndTimeAccessor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndTimeAccessor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndTimeAccessor.java index 833079b..8131385 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndTimeAccessor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/accessors/TemporalIntervalEndTimeAccessor.java @@ -70,8 +70,8 @@ public class TemporalIntervalEndTimeAccessor extends AbstractScalarFunctionDynam // 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 @@ -83,8 +83,8 @@ public class TemporalIntervalEndTimeAccessor extends AbstractScalarFunctionDynam resultStorage.reset(); try { if (bytes[startOffset] == ATypeTag.SERIALIZED_INTERVAL_TYPE_TAG) { - byte timeType = AIntervalSerializerDeserializer.getIntervalTimeType(bytes, - startOffset + 1); + byte timeType = + AIntervalSerializerDeserializer.getIntervalTimeType(bytes, startOffset + 1); long endTime = AIntervalSerializerDeserializer.getIntervalEnd(bytes, startOffset + 1); if (timeType == ATypeTag.SERIALIZED_TIME_TYPE_TAG) { aTime.setValue((int) (endTime));
