Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use GenericIndexed v2 supported read() during deserializeColumn (#4463)

This commit is contained in:
Akash Dwivedi 2017-07-11 08:18:25 -07:00 committed by Himanshu
parent 5f411f14af
commit a108d05f76
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
extensions-core/datasketches/src/main/java/io/druid/query/aggregation/datasketches/theta/SketchMergeComplexMetricSerde.java
View File

@ -69,7 +69,7 @@ public class SketchMergeComplexMetricSerde extends ComplexMetricSerde
@Override @Override
public void deserializeColumn(ByteBuffer buffer, ColumnBuilder builder) public void deserializeColumn(ByteBuffer buffer, ColumnBuilder builder)
{ {
GenericIndexed<Sketch> ge = GenericIndexed.read(buffer, strategy); GenericIndexed<Sketch> ge = GenericIndexed.read(buffer, strategy, builder.getFileMapper());
builder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), ge)); builder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), ge));
} }

2
extensions-core/histogram/src/main/java/io/druid/query/aggregation/histogram/ApproximateHistogramFoldingSerde.java
View File

@ -97,7 +97,7 @@ public class ApproximateHistogramFoldingSerde extends ComplexMetricSerde
ByteBuffer byteBuffer, ColumnBuilder columnBuilder 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)); columnBuilder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), column));
} }

2
extensions-core/stats/src/main/java/io/druid/query/aggregation/variance/VarianceSerde.java
View File

@ -85,7 +85,7 @@ public class VarianceSerde extends ComplexMetricSerde
ByteBuffer byteBuffer, ColumnBuilder columnBuilder 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)); columnBuilder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), column));
} }

2
processing/src/main/java/io/druid/query/aggregation/hyperloglog/HyperUniquesSerde.java
View File

@ -102,7 +102,7 @@ public class HyperUniquesSerde extends ComplexMetricSerde
ByteBuffer byteBuffer, ColumnBuilder columnBuilder 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)); columnBuilder.setComplexColumn(new ComplexColumnPartSupplier(getTypeName(), column));
} }