Package org.apache.druid.segment.nested

Class NestedDataComplexTypeSerde

java.lang.Object

org.apache.druid.segment.serde.ComplexMetricSerde

org.apache.druid.segment.nested.NestedDataComplexTypeSerde

public class NestedDataComplexTypeSerde
extends ComplexMetricSerde

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NestedDataComplexTypeSerde.NestedColumnFormatV4

Field Summary

Fields

Modifier and Type	Field	Description
static final NestedDataComplexTypeSerde	INSTANCE
static final String	TYPE_NAME

Constructor Summary

Constructors

Constructor	Description
NestedDataComplexTypeSerde()

Method Summary

Modifier and Type	Method	Description
void	deserializeColumn(ByteBuffer buffer, ColumnBuilder builder)	ComplexMetricSerde.deserializeColumn(ByteBuffer, ColumnBuilder, ColumnConfig) should be used instead of this.
void	deserializeColumn(ByteBuffer buffer, ColumnBuilder builder, ColumnConfig columnConfig)	Deserializes a ByteBuffer and adds it to the ColumnBuilder.
ComplexMetricExtractor	getExtractor()
ObjectStrategy<Object>	getObjectStrategy()	This is deprecated because its usage is going to be removed from the code.
String	getTypeName()
TypeStrategy<Object>	getTypeStrategy()	Get a TypeStrategy to assist with writing individual complex values to a ByteBuffer.
byte[]	toBytes(Object val)	Converts intermediate representation of aggregate to byte[].

Methods inherited from class org.apache.druid.segment.serde.ComplexMetricSerde

fromBytes, getSerializer, getSerializer, inputSizeFn

Methods inherited from class java.lang.Object

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

Field Details

TYPE_NAME

public static final String TYPE_NAME

See Also:

• Constant Field Values

INSTANCE

public static final NestedDataComplexTypeSerde INSTANCE

Constructor Details

NestedDataComplexTypeSerde

public NestedDataComplexTypeSerde()

Method Details

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

ComplexMetricSerde.deserializeColumn(ByteBuffer, ColumnBuilder, ColumnConfig) should be used instead of this. This method is left for backward compatibility.

Overrides:

deserializeColumn in class ComplexMetricSerde

deserializeColumn

public void deserializeColumn(ByteBuffer buffer,
 ColumnBuilder builder,
 ColumnConfig columnConfig)

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.

Overrides:

deserializeColumn in class ComplexMetricSerde

Parameters:

buffer - the buffer to deserialize

builder - ColumnBuilder to add the column to

columnConfig - ColumnConfiguration used during deserialization

getObjectStrategy

public ObjectStrategy<Object> 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

getTypeStrategy

public TypeStrategy<Object> getTypeStrategy()

Description copied from class: ComplexMetricSerde

Get a TypeStrategy to assist with writing individual complex values to a ByteBuffer.

Overrides:

getTypeStrategy in class ComplexMetricSerde

See Also:

• TypeStrategy

toBytes

public byte[] toBytes(@Nullable
 Object val)

Description copied from class: ComplexMetricSerde

Converts intermediate representation of aggregate to byte[].

Overrides:

toBytes in class ComplexMetricSerde

Parameters:

val - intermediate representation of aggregate

Returns:

serialized intermediate representation of aggregate in byte[]