Package org.apache.druid.segment.nested

Class ScalarDoubleColumnSerializer

java.lang.Object

org.apache.druid.segment.nested.NestedCommonFormatColumnSerializer

org.apache.druid.segment.nested.ScalarNestedCommonFormatColumnSerializer<Double>

org.apache.druid.segment.nested.ScalarDoubleColumnSerializer

All Implemented Interfaces:

GenericColumnSerializer<StructuredData>, Serializer

public class ScalarDoubleColumnSerializer
extends ScalarNestedCommonFormatColumnSerializer<Double>

Serializer for a ScalarDoubleColumn

Field Summary

Fields inherited from class org.apache.druid.segment.nested.ScalarNestedCommonFormatColumnSerializer

closedForWrite, closer, columnFormatSpec, columnNameBytes, dictionaryIdLookup, dictionarySerialized, dictionaryWriter, hasNulls, intermediateValueWriter, log, name, segmentWriteOutMedium, writeDictionary

Fields inherited from class org.apache.druid.segment.nested.NestedCommonFormatColumnSerializer

NESTED_FIELD_PREFIX, RAW_FILE_NAME, V0

Constructor Summary

Constructors

Constructor	Description
ScalarDoubleColumnSerializer(String name, NestedCommonFormatColumnFormatSpec columnFormatSpec, SegmentWriteOutMedium segmentWriteOutMedium, Closer closer)

Method Summary

Modifier and Type	Method	Description
int	getCardinality()
void	openDictionaryWriter(File segmentBaseDir)
protected void	openValueColumnSerializer()	Called during ScalarNestedCommonFormatColumnSerializer.open() to allow opening any separate type specific value column serializers
protected int	processValue(Object rawValue)	Called during ScalarNestedCommonFormatColumnSerializer.serialize(ColumnValueSelector) to convert value to dictionary id.
void	serializeDictionaries(Iterable<String> strings, Iterable<Long> longs, Iterable<Double> doubles, Iterable<int[]> arrays)
protected void	writeDictionaryFile(SegmentFileBuilder fileBuilder)
protected void	writeValueColumn(SegmentFileBuilder fileBuilder)	Called during Serializer.writeTo(WritableByteChannel, SegmentFileBuilder) to allow any type specific value column serializers to use the SegmentFileBuilder to write stuff to places.

Methods inherited from class org.apache.druid.segment.nested.ScalarNestedCommonFormatColumnSerializer

getColumnName, getDictionaryIdLookup, getSerializedSize, hasNulls, open, serialize, setDictionaryIdLookup, writeTo

Methods inherited from class org.apache.druid.segment.nested.NestedCommonFormatColumnSerializer

computeFilenameBytes, copyFromTempSmoosh, serializeFields, writeInternal, writeV0Header

Methods inherited from class java.lang.Object

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

Constructor Details

ScalarDoubleColumnSerializer

public ScalarDoubleColumnSerializer(String name,
 NestedCommonFormatColumnFormatSpec columnFormatSpec,
 SegmentWriteOutMedium segmentWriteOutMedium,
 Closer closer)

Method Details

processValue

protected int processValue(@Nullable
 Object rawValue)
                    throws IOException

Description copied from class: ScalarNestedCommonFormatColumnSerializer

Called during ScalarNestedCommonFormatColumnSerializer.serialize(ColumnValueSelector) to convert value to dictionary id.

Implementations may optionally also serialize the value to a type specific value column if they opened one with ScalarNestedCommonFormatColumnSerializer.openValueColumnSerializer(), or do whatever else is useful to do while handling a single row value.

Specified by:

processValue in class ScalarNestedCommonFormatColumnSerializer<Double>

Throws:

IOException

openDictionaryWriter

public void openDictionaryWriter(File segmentBaseDir)
                          throws IOException

Specified by:

openDictionaryWriter in class NestedCommonFormatColumnSerializer

Throws:

IOException

openValueColumnSerializer

protected void openValueColumnSerializer()
                                  throws IOException

Description copied from class: ScalarNestedCommonFormatColumnSerializer

Called during ScalarNestedCommonFormatColumnSerializer.open() to allow opening any separate type specific value column serializers

Specified by:

openValueColumnSerializer in class ScalarNestedCommonFormatColumnSerializer<Double>

Throws:

IOException

serializeDictionaries

public void serializeDictionaries(Iterable<String> strings,
 Iterable<Long> longs,
 Iterable<Double> doubles,
 Iterable<int[]> arrays)
                           throws IOException

Specified by:

serializeDictionaries in class NestedCommonFormatColumnSerializer

Throws:

IOException

writeValueColumn

protected void writeValueColumn(SegmentFileBuilder fileBuilder)
                         throws IOException

Description copied from class: ScalarNestedCommonFormatColumnSerializer

Called during Serializer.writeTo(WritableByteChannel, SegmentFileBuilder) to allow any type specific value column serializers to use the SegmentFileBuilder to write stuff to places.

Specified by:

writeValueColumn in class ScalarNestedCommonFormatColumnSerializer<Double>

Throws:

IOException

writeDictionaryFile

protected void writeDictionaryFile(SegmentFileBuilder fileBuilder)
                            throws IOException

Specified by:

writeDictionaryFile in class ScalarNestedCommonFormatColumnSerializer<Double>

Throws:

IOException

getCardinality

public int getCardinality()

Specified by:

getCardinality in class ScalarNestedCommonFormatColumnSerializer<Double>