Fix setting of metrics compression type in RealtimeSegmentConverter
Remove overriding compression type for metrics in RealtimeSegmentConverter
@@ -20,7 +20,6 @@ package org.apache.pinot.segment.local.realtime.converter;
import com.google.common.annotations.VisibleForTesting;
import java.util.ArrayList;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.annotation.Nullable;
@@ -31,13 +30,11 @@ import org.apache.pinot.segment.local.realtime.converter.stats.RealtimeSegmentSe
import org.apache.pinot.segment.local.recordtransformer.CompositeTransformer;
import org.apache.pinot.segment.local.segment.creator.impl.SegmentIndexCreationDriverImpl;
import org.apache.pinot.segment.local.segment.readers.PinotSegmentRecordReader;
-import org.apache.pinot.segment.spi.compression.ChunkCompressionType;
import org.apache.pinot.segment.spi.creator.SegmentGeneratorConfig;
import org.apache.pinot.segment.spi.creator.SegmentVersion;
import org.apache.pinot.spi.config.table.ColumnPartitionConfig;
import org.apache.pinot.spi.config.table.SegmentPartitionConfig;
import org.apache.pinot.spi.config.table.TableConfig;
-import org.apache.pinot.spi.data.FieldSpec;
import org.apache.pinot.spi.data.Schema;
@@ -92,17 +89,6 @@ public class RealtimeSegmentConverter {
genConfig.createInvertedIndexForColumn(column);
}
}
- if (_noDictionaryColumns != null) {
- genConfig.setRawIndexCreationColumns(_noDictionaryColumns);
- Map<String, ChunkCompressionType> columnToCompressionType = new HashMap<>();
- for (String column : _noDictionaryColumns) {
- FieldSpec fieldSpec = _dataSchema.getFieldSpecFor(column);
- if (fieldSpec.getFieldType().equals(FieldSpec.FieldType.METRIC)) {
- columnToCompressionType.put(column, ChunkCompressionType.PASS_THROUGH);
- }
- }
- genConfig.setRawIndexCompressionType(columnToCompressionType);
- }
if (_varLengthDictionaryColumns != null) {
genConfig.setVarLengthDictionaryColumns(_varLengthDictionaryColumns);
