diff --git a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchMergeComplexMetricSerde.java b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchMergeComplexMetricSerde.java index a5651616222..e0c1ba03bab 100644 --- a/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchMergeComplexMetricSerde.java +++ b/extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchMergeComplexMetricSerde.java @@ -69,7 +69,7 @@ public class SketchMergeComplexMetricSerde extends ComplexMetricSerde @Override public void deserializeColumn(ByteBuffer buffer, ColumnBuilder builder) { - GenericIndexed ge = GenericIndexed.read(buffer, strategy); + GenericIndexed ge = GenericIndexed.read(buffer, strategy, builder.getFileMapper()); builder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), ge)); } diff --git a/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingSerde.java b/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingSerde.java index d1e20092a32..b1ad2f883b1 100644 --- a/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingSerde.java +++ b/extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingSerde.java @@ -97,7 +97,7 @@ public class ApproximateHistogramFoldingSerde extends ComplexMetricSerde ByteBuffer byteBuffer, ColumnBuilder columnBuilder ) { - final GenericIndexed column = GenericIndexed.read(byteBuffer, getObjectStrategy()); + final GenericIndexed column = GenericIndexed.read(byteBuffer, getObjectStrategy(), columnBuilder.getFileMapper()); columnBuilder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), column)); } diff --git a/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceSerde.java b/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceSerde.java index 3bcb988a200..1ed59fff48c 100644 --- a/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceSerde.java +++ b/extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceSerde.java @@ -85,7 +85,7 @@ public class VarianceSerde extends ComplexMetricSerde ByteBuffer byteBuffer, ColumnBuilder columnBuilder ) { - final GenericIndexed column = GenericIndexed.read(byteBuffer, getObjectStrategy()); + final GenericIndexed column = GenericIndexed.read(byteBuffer, getObjectStrategy(), columnBuilder.getFileMapper()); columnBuilder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), column)); } diff --git a/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesSerde.java b/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesSerde.java index 0ab39581c1a..26fda75b9aa 100644 --- a/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesSerde.java +++ b/processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesSerde.java @@ -102,7 +102,7 @@ public class HyperUniquesSerde extends ComplexMetricSerde ByteBuffer byteBuffer, ColumnBuilder columnBuilder ) { - final GenericIndexed column = GenericIndexed.read(byteBuffer, getObjectStrategy()); + final GenericIndexed column = GenericIndexed.read(byteBuffer, getObjectStrategy(), columnBuilder.getFileMapper()); columnBuilder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), column)); }