io.druid.segment

Class LongDimensionMergerLegacy

java.lang.Object

io.druid.segment.LongDimensionMergerV9

io.druid.segment.LongDimensionMergerLegacy

All Implemented Interfaces:

DimensionMerger<Long>, DimensionMergerLegacy<Long>, DimensionMergerV9<Long>

public class LongDimensionMergerLegacy
extends LongDimensionMergerV9
implements DimensionMergerLegacy<Long>

Field Summary

Fields inherited from class io.druid.segment.LongDimensionMergerV9

capabilities, dimensionName, indexSpec, ioPeon, outDir, progress, serializer

Constructor Summary

Constructors

Constructor and Description
LongDimensionMergerLegacy(String dimensionName, IndexSpec indexSpec, File outDir, IOPeon ioPeon, ColumnCapabilities capabilities, ProgressIndicator progress)

Method Summary

Modifier and Type	Method and Description
File	makeDimFile()
void	processMergedRow(Long rowValues) Process a key component from the merged sequence of rows and update the DimensionMerger's internal state.
protected void	setupEncodedValueWriter()
void	writeIndexesToFiles(com.google.common.io.ByteSink invertedOut, com.google.common.io.OutputSupplier<FileOutputStream> spatialOut) Write this dimension's bitmap and spatial indexes to a file.
void	writeRowValuesToFile(FileOutputSupplier rowValueOut) Write this dimension's sequence of row values to a file.
void	writeValueMetadataToFile(FileOutputSupplier valueEncodingFile) Write this dimension's value metadata to a file.

Methods inherited from class io.druid.segment.LongDimensionMergerV9

canSkip, convertSegmentRowValuesToMergedRowValues, makeColumnDescriptor, writeIndexes, writeMergedValueMetadata

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.segment.DimensionMergerV9

makeColumnDescriptor

Methods inherited from interface io.druid.segment.DimensionMerger

canSkip, convertSegmentRowValuesToMergedRowValues, writeIndexes, writeMergedValueMetadata

Constructor Detail

LongDimensionMergerLegacy

public LongDimensionMergerLegacy(String dimensionName,
                                 IndexSpec indexSpec,
                                 File outDir,
                                 IOPeon ioPeon,
                                 ColumnCapabilities capabilities,
                                 ProgressIndicator progress)

Method Detail

setupEncodedValueWriter

protected void setupEncodedValueWriter()
                                throws IOException

Overrides:

setupEncodedValueWriter in class LongDimensionMergerV9

Throws:

IOException

processMergedRow

public void processMergedRow(Long rowValues)
                      throws IOException

Description copied from interface: DimensionMerger

Process a key component from the merged sequence of rows and update the DimensionMerger's internal state. After constructing a merged sequence of rows across segments, the index merging process will iterate through these rows and pass row key components from each dimension to their corresponding DimensionMergers. This allows each DimensionMerger to build its internal view of the sequence of merged rows, to be written out to a segment later.

Specified by:

processMergedRow in interface DimensionMerger<Long>

Overrides:

processMergedRow in class LongDimensionMergerV9

Parameters:

rowValues - The row values to be added.

Throws:

IOException

writeValueMetadataToFile

public void writeValueMetadataToFile(FileOutputSupplier valueEncodingFile)
                              throws IOException

Description copied from interface: DimensionMergerLegacy

Write this dimension's value metadata to a file.

Specified by:

writeValueMetadataToFile in interface DimensionMergerLegacy<Long>

Parameters:

valueEncodingFile - Destination file

Throws:

IOException

writeRowValuesToFile

public void writeRowValuesToFile(FileOutputSupplier rowValueOut)
                          throws IOException

Description copied from interface: DimensionMergerLegacy

Write this dimension's sequence of row values to a file.

Specified by:

writeRowValuesToFile in interface DimensionMergerLegacy<Long>

Parameters:

rowValueOut - Destination file

Throws:

IOException

writeIndexesToFiles

public void writeIndexesToFiles(com.google.common.io.ByteSink invertedOut,
                                com.google.common.io.OutputSupplier<FileOutputStream> spatialOut)
                         throws IOException

Description copied from interface: DimensionMergerLegacy

Write this dimension's bitmap and spatial indexes to a file.

Specified by:

writeIndexesToFiles in interface DimensionMergerLegacy<Long>

Parameters:

invertedOut - Destination file for bitmap indexes

spatialOut - Destination file for spatial indexes

Throws:

IOException

makeDimFile

public File makeDimFile()
                 throws IOException

Specified by:

makeDimFile in interface DimensionMergerLegacy<Long>

Throws:

IOException