Uses of Interface
org.apache.druid.segment.IndexableAdapter
Packages that use IndexableAdapter
-
Uses of IndexableAdapter in org.apache.druid.segment
Classes in org.apache.druid.segment that implement IndexableAdapterFields in org.apache.druid.segment with type parameters of type IndexableAdapterModifier and TypeFieldDescriptionprotected List<IndexableAdapter>DictionaryEncodedColumnMerger.adaptersMethods in org.apache.druid.segment that return IndexableAdapterModifier and TypeMethodDescriptionIndexableAdapter.getProjectionAdapter(String projection) QueryableIndexIndexableAdapter.getProjectionAdapter(String projection) Methods in org.apache.druid.segment that return types with arguments of type IndexableAdapterModifier and TypeMethodDescriptionprotected List<List<IndexableAdapter>>IndexMergerBase.getMergePhases(List<IndexableAdapter> indexes, int maxColumnsToMerge) static List<IndexableAdapter>IndexMerger.toIndexableAdapters(List<QueryableIndex> indexes) Methods in org.apache.druid.segment with parameters of type IndexableAdapterModifier and TypeMethodDescriptionprotected intIndexMergerBase.getIndexColumnCount(IndexableAdapter indexableAdapter) voidIndexIO.validateTwoSegments(IndexableAdapter adapter1, IndexableAdapter adapter2) Method parameters in org.apache.druid.segment with type arguments of type IndexableAdapterModifier and TypeMethodDescriptionvoidAutoTypeColumnMerger.attachParent(DimensionMergerV9 parent, List<IndexableAdapter> projectionAdapters) default voidDimensionMergerV9.attachParent(DimensionMergerV9 parent, List<IndexableAdapter> projectionAdapters) Attaches theDimensionMergerV9of a "projection" parent column so that stuff like value dictionaries can be shared between parent and child.voidStringDimensionMergerV9.attachParent(DimensionMergerV9 parent, List<IndexableAdapter> projectionAdapters) protected intIndexMergerBase.getIndexColumnCount(List<IndexableAdapter> indexableAdapters) IndexMerger.getLexicographicMergedDimensions(List<IndexableAdapter> indexes) ReturnsColumnHolder.TIME_COLUMN_NAMEfollowed by a merged list of dimensions in lexicographic order.IndexMerger.getLongestSharedDimOrder(List<IndexableAdapter> indexes, DimensionsSpec dimensionsSpec) Gets the longest shared dimension order, including bothColumnHolder.TIME_COLUMN_NAMEand dimensions.IndexMerger.getMergedDimensionsWithTime(List<IndexableAdapter> indexes, DimensionsSpec dimensionsSpec) Returns a merged list of dimensions, includingColumnHolder.TIME_COLUMN_NAME, that will be used to buildTimeAndDimsPointer.protected List<List<IndexableAdapter>>IndexMergerBase.getMergePhases(List<IndexableAdapter> indexes, int maxColumnsToMerge) static booleanIndexMerger.isDimensionOrderingValid(List<IndexableAdapter> indexes, Iterable<String> orderingCandidate) protected abstract FileIndexMergerBase.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) MergeIndexableAdapterand build the segment fileprotected FileIndexMergerV10.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) protected FileIndexMergerV9.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) protected TimeAndDimsIteratorIndexMergerBase.makeMergedTimeAndDimsIterator(List<IndexableAdapter> indexes, List<String> mergedDimensionsWithTime, List<String> mergedMetrics, Function<List<TransformableRowIterator>, TimeAndDimsIterator> rowMergerFn, Map<String, DimensionHandler> handlers, List<DimensionMergerV9> mergers) IndexMerger.merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, DimensionsSpec dimensionsSpec, IndexSpec indexSpec, int maxColumnsToMerge) Only used as a convenience method in tests.IndexMergerBase.merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, DimensionsSpec dimensionsSpec, IndexSpec indexSpec, int maxColumnsToMerge) The indexes here must have the sameMetadata, otherwise an error would be thrown.protected FileIndexMergerBase.merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, DimensionsSpec dimensionsSpec, File outDir, IndexSpec indexSpec, ProgressIndicator progress, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) protected voidIndexMergerBase.mergeFormat(List<IndexableAdapter> adapters, List<String> mergedDimensions, Map<String, ColumnFormat> metricTypes, List<ColumnFormat> dimFormats) protected IndexMergerBase.IndexMergeResultIndexMergerBase.mergeIndexesAndWriteColumns(List<IndexableAdapter> adapters, ProgressIndicator progress, TimeAndDimsIterator timeAndDimsIterator, GenericColumnSerializer timeWriter, ArrayList<GenericColumnSerializer> metricWriters, List<DimensionMergerV9> mergers) Returns rowNumConversions, if fillRowNumConversions argument is trueprotected FileIndexMergerBase.multiphaseMerge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, DimensionsSpec dimensionsSpec, File outDir, IndexSpec indexSpec, IndexSpec indexSpecForIntermediatePersists, ProgressIndicator progress, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, int maxColumnsToMerge) protected DictionaryEncodedColumnMerger.IndexSeeker[]DictionaryEncodedColumnMerger.toIndexSeekers(List<IndexableAdapter> adapters, ArrayList<IntBuffer> dimConversions, String dimension) protected voidIndexMergerBase.writeDimValuesAndSetupDimConversion(List<IndexableAdapter> indexes, ProgressIndicator progress, List<String> mergedDimensions, List<DimensionMergerV9> mergers) voidAutoTypeColumnMerger.writeMergedValueDictionary(List<IndexableAdapter> adapters) voidDictionaryEncodedColumnMerger.writeMergedValueDictionary(List<IndexableAdapter> adapters) voidDimensionMerger.writeMergedValueDictionary(List<IndexableAdapter> adapters) Given a list of segment adapters: - Read _sorted order_ (e.final voidNumericDimensionMergerV9.writeMergedValueDictionary(List<IndexableAdapter> adapters) -
Uses of IndexableAdapter in org.apache.druid.segment.incremental
Classes in org.apache.druid.segment.incremental that implement IndexableAdapterMethods in org.apache.druid.segment.incremental that return IndexableAdapterModifier and TypeMethodDescriptionIncrementalIndexAdapter.getProjectionAdapter(String projection)