Package org.apache.druid.segment

Class IndexMergerV9

java.lang.Object

org.apache.druid.segment.IndexMergerBase

org.apache.druid.segment.IndexMergerV9

All Implemented Interfaces:

IndexMerger

public class IndexMergerV9
extends IndexMergerBase

IndexMerger for creating v9 format segments with FileSmoosher

See Also:

• FileSmoosher
• to read the resulting segment files

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.druid.segment.IndexMergerBase

IndexMergerBase.DimensionsSpecInspector, IndexMergerBase.IndexMergeResult

Field Summary

Fields inherited from class org.apache.druid.segment.IndexMergerBase

defaultSegmentWriteOutMediumFactory, indexIO, mapper

Fields inherited from interface org.apache.druid.segment.IndexMerger

INVALID_ROW, SERIALIZER_UTILS, UNLIMITED_MAX_COLUMNS_TO_MERGE

Constructor Summary

Constructors

Constructor	Description
IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper, IndexIO indexIO, SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory)	This constructor is used only for tests
IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper, IndexIO indexIO, SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory, boolean storeEmptyColumns)

Method Summary

Modifier and Type	Method	Description
protected void	makeColumn(SegmentFileBuilder segmentFileBuilder, String columnName, ColumnDescriptor serdeficator)	Add a column specified by a ColumnDescriptor to a SegmentFileBuilder
protected File	makeIndexFiles(List<IndexableAdapter> adapters, Metadata segmentMetadata, File outDir, ProgressIndicator progress, List<String> mergedDimensionsWithTime, IndexMergerBase.DimensionsSpecInspector dimensionsSpecInspector, List<String> mergedMetrics, Function<List<TransformableRowIterator>,TimeAndDimsIterator> rowMergerFn, IndexSpec indexSpec, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)	Merge IndexableAdapter and build the segment file
protected boolean	shouldStoreEmptyColumns()	Should the segment track columns which were specified in the ingestion spec, but not present in the processed data?

Methods inherited from class org.apache.druid.segment.IndexMergerBase

getIndexColumnCount, getIndexColumnCount, getMergePhases, makeDimensionHandlers, makeMergedTimeAndDimsIterator, makeMetricsColumns, makeProjections, makeTimeColumn, merge, merge, mergeFormat, mergeIndexesAndWriteColumns, mergeQueryableIndex, multiphaseMerge, persist, setupMetricsWriters, setupTimeWriter, writeDimValuesAndSetupDimConversion

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.segment.IndexMerger

mergeQueryableIndex, mergeQueryableIndex, persist, persist

Constructor Details

IndexMergerV9

public IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper,
 IndexIO indexIO,
 SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory,
 boolean storeEmptyColumns)

IndexMergerV9

public IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper,
 IndexIO indexIO,
 SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory)

This constructor is used only for tests

Method Details

shouldStoreEmptyColumns

protected boolean shouldStoreEmptyColumns()

Description copied from class: IndexMergerBase

Should the segment track columns which were specified in the ingestion spec, but not present in the processed data?

Specified by:

shouldStoreEmptyColumns in class IndexMergerBase

makeIndexFiles

protected File makeIndexFiles(List<IndexableAdapter> adapters,
 @Nullable
 Metadata segmentMetadata,
 File outDir,
 ProgressIndicator progress,
 List<String> mergedDimensionsWithTime,
 IndexMergerBase.DimensionsSpecInspector dimensionsSpecInspector,
 List<String> mergedMetrics,
 Function<List<TransformableRowIterator>,TimeAndDimsIterator> rowMergerFn,
 IndexSpec indexSpec,
 @Nullable
 SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
                       throws IOException

Description copied from class: IndexMergerBase

Merge IndexableAdapter and build the segment file

Specified by:

makeIndexFiles in class IndexMergerBase

Throws:

IOException

makeColumn

protected void makeColumn(SegmentFileBuilder segmentFileBuilder,
 String columnName,
 ColumnDescriptor serdeficator)
                   throws IOException

Description copied from class: IndexMergerBase

Add a column specified by a ColumnDescriptor to a SegmentFileBuilder

Specified by:

makeColumn in class IndexMergerBase

Throws:

IOException