Repository: asterixdb Updated Branches: refs/heads/master df268b19a -> 8a742fd19
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/8a742fd1/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/runningaggregates/std/TidRunningAggregateDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/runningaggregates/std/TidRunningAggregateDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/runningaggregates/std/TidRunningAggregateDescriptor.java index b3a17aa..6c7ccb6 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/runningaggregates/std/TidRunningAggregateDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/runningaggregates/std/TidRunningAggregateDescriptor.java @@ -18,7 +18,7 @@ */ package org.apache.asterix.runtime.runningaggregates.std; -import org.apache.asterix.formats.nontagged.AqlSerializerDeserializerProvider; +import org.apache.asterix.formats.nontagged.SerializerDeserializerProvider; import org.apache.asterix.om.base.AInt64; import org.apache.asterix.om.base.AMutableInt64; import org.apache.asterix.om.functions.AsterixBuiltinFunctions; @@ -60,7 +60,7 @@ public class TidRunningAggregateDescriptor extends AbstractRunningAggregateFunct return new IRunningAggregateEvaluator() { private final ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); - private final ISerializerDeserializer<AInt64> serde = AqlSerializerDeserializerProvider.INSTANCE + private final ISerializerDeserializer<AInt64> serde = SerializerDeserializerProvider.INSTANCE .getSerializerDeserializer(BuiltinType.AINT64); private final AMutableInt64 m = new AMutableInt64(0); private int cnt; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/8a742fd1/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/unnestingfunctions/std/RangeDescriptor.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/unnestingfunctions/std/RangeDescriptor.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/unnestingfunctions/std/RangeDescriptor.java index 6acb8d4..dc19156 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/unnestingfunctions/std/RangeDescriptor.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/unnestingfunctions/std/RangeDescriptor.java @@ -18,7 +18,7 @@ */ package org.apache.asterix.runtime.unnestingfunctions.std; -import org.apache.asterix.formats.nontagged.AqlSerializerDeserializerProvider; +import org.apache.asterix.formats.nontagged.SerializerDeserializerProvider; import org.apache.asterix.om.base.AMutableInt64; import org.apache.asterix.om.functions.AsterixBuiltinFunctions; import org.apache.asterix.om.functions.IFunctionDescriptor; @@ -67,7 +67,7 @@ public class RangeDescriptor extends AbstractUnnestingFunctionDynamicDescriptor return new IUnnestingEvaluator() { private ArrayBackedValueStorage resultStorage = new ArrayBackedValueStorage(); @SuppressWarnings("rawtypes") - private ISerializerDeserializer serde = AqlSerializerDeserializerProvider.INSTANCE + private ISerializerDeserializer serde = SerializerDeserializerProvider.INSTANCE .getSerializerDeserializer(BuiltinType.AINT64); private IPointable inputVal = new VoidPointable(); private IScalarEvaluator eval0 = args[0].createScalarEvaluator(ctx);
