io.druid.query.aggregation.datasketches.theta

Class SketchMergeComplexMetricSerde

java.lang.Object

io.druid.segment.serde.ComplexMetricSerde

io.druid.query.aggregation.datasketches.theta.SketchMergeComplexMetricSerde

Direct Known Subclasses:

SketchBuildComplexMetricSerde

public class SketchMergeComplexMetricSerde
extends ComplexMetricSerde

Constructor Summary

Constructors

Constructor and Description
SketchMergeComplexMetricSerde()

Method Summary

Modifier and Type	Method and Description
void	deserializeColumn(ByteBuffer buffer, ColumnBuilder builder) Deserializes a ByteBuffer and adds it to the ColumnBuilder.
ComplexMetricExtractor	getExtractor()
ObjectStrategy<com.yahoo.sketches.theta.Sketch>	getObjectStrategy() This is deprecated because its usage is going to be removed from the code.
GenericColumnSerializer	getSerializer(IOPeon peon, String column) This method provides the ability for a ComplexMetricSerde to control its own serialization.
String	getTypeName()

Methods inherited from class io.druid.segment.serde.ComplexMetricSerde

fromBytes, inputSizeFn, toBytes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SketchMergeComplexMetricSerde

public SketchMergeComplexMetricSerde()

Method Detail

getTypeName

public String getTypeName()

Specified by:

getTypeName in class ComplexMetricSerde

getExtractor

public ComplexMetricExtractor getExtractor()

Specified by:

getExtractor in class ComplexMetricSerde

deserializeColumn

public void deserializeColumn(ByteBuffer buffer,
                              ColumnBuilder builder)

Description copied from class: ComplexMetricSerde

Deserializes a ByteBuffer and adds it to the ColumnBuilder. This method allows for the ComplexMetricSerde to implement it's own versioning scheme to allow for changes of binary format in a forward-compatible manner.

Specified by:

deserializeColumn in class ComplexMetricSerde

Parameters:

buffer - the buffer to deserialize

builder - ColumnBuilder to add the column to

getObjectStrategy

public ObjectStrategy<com.yahoo.sketches.theta.Sketch> getObjectStrategy()

Description copied from class: ComplexMetricSerde

This is deprecated because its usage is going to be removed from the code.

It was introduced before deserializeColumn() existed. This method creates the assumption that Druid knows how to interpret the actual column representation of the data, but I would much prefer that the ComplexMetricSerde objects be in charge of creating and interpreting the whole column, which is what deserializeColumn lets them do.

Specified by:

getObjectStrategy in class ComplexMetricSerde

Returns:

an ObjectStrategy as used by GenericIndexed

getSerializer

public GenericColumnSerializer getSerializer(IOPeon peon,
                                             String column)

Description copied from class: ComplexMetricSerde

This method provides the ability for a ComplexMetricSerde to control its own serialization. For large column (i.e columns greater than Integer.MAX) use (@link LargeColumnSupportedComplexColumnSerializer)

Overrides:

getSerializer in class ComplexMetricSerde

Parameters:

peon - IOPeon

column - name of the column

Returns:

an instance of GenericColumnSerializer used for serialization.