Package org.apache.druid.segment

Class IndexMergerV10

java.lang.Object

org.apache.druid.segment.IndexMergerBase

org.apache.druid.segment.IndexMergerV10

All Implemented Interfaces:

IndexMerger

public class IndexMergerV10
extends IndexMergerBase

IndexMerger for creating v10 format segments with SegmentFileBuilderV10

See Also:

• SegmentFileBuilderV10
• to read the resulting segment file

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
IndexMergerV10(com.fasterxml.jackson.databind.ObjectMapper mapper, IndexIO indexIO, SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory)

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

IndexMergerV10

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

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