Uses of Interface
org.apache.druid.segment.ColumnSelectorFactory
Packages that use ColumnSelectorFactory
Package
Description
-
Uses of ColumnSelectorFactory in org.apache.druid.frame.field
Methods in org.apache.druid.frame.field with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic FieldWriterFieldWriters.create(FrameType frameType, ColumnSelectorFactory columnSelectorFactory, String columnName, ColumnType columnType, boolean removeNullBytes) Helper used byRowBasedFrameWriterFactory. -
Uses of ColumnSelectorFactory in org.apache.druid.frame.processor
Classes in org.apache.druid.frame.processor that implement ColumnSelectorFactoryModifier and TypeClassDescriptionclassAColumnSelectorFactorythat wraps multipleColumnSelectorFactoryand delegates to one of them at any given time.Constructor parameters in org.apache.druid.frame.processor with type arguments of type ColumnSelectorFactoryModifierConstructorDescriptionMultiColumnSelectorFactory(List<Supplier<ColumnSelectorFactory>> factorySuppliers, RowSignature signature) -
Uses of ColumnSelectorFactory in org.apache.druid.frame.read
Methods in org.apache.druid.frame.read with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic Supplier<MemoryRange<org.apache.datasketches.memory.Memory>> FrameReaderUtils.makeRowMemorySupplier(ColumnSelectorFactory columnSelectorFactory, FrameType expectedFrameType, RowSignature expectedSignature) Returns a direct row memory supplier ifFrameReaderUtils.mayBeAbleToSelectRowMemory(org.apache.druid.segment.ColumnSelectorFactory), otherwise returns null. -
Uses of ColumnSelectorFactory in org.apache.druid.frame.segment
Methods in org.apache.druid.frame.segment that return ColumnSelectorFactoryConstructors in org.apache.druid.frame.segment with parameters of type ColumnSelectorFactoryModifierConstructorDescriptionFrameCursor(SimpleSettableOffset offset, ColumnSelectorFactory columnSelectorFactory) FrameFilteredOffset(SimpleSettableOffset baseOffset, ColumnSelectorFactory columnSelectorFactory, Filter postFilter) -
Uses of ColumnSelectorFactory in org.apache.druid.frame.segment.row
Classes in org.apache.druid.frame.segment.row that implement ColumnSelectorFactory -
Uses of ColumnSelectorFactory in org.apache.druid.frame.util
Methods in org.apache.druid.frame.util with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionSettableLongVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) SettableLongVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) -
Uses of ColumnSelectorFactory in org.apache.druid.frame.write
Methods in org.apache.druid.frame.write with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionFrameWriterFactory.newFrameWriter(ColumnSelectorFactory columnSelectorFactory) Create a writer whereFrameWriter.addSelection()adds the current row from aColumnSelectorFactory.RowBasedFrameWriterFactory.newFrameWriter(ColumnSelectorFactory columnSelectorFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.frame.write.cast
Methods in org.apache.druid.frame.write.cast with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic ColumnValueSelector<?> TypeCastSelectors.makeColumnValueSelector(ColumnSelectorFactory columnSelectorFactory, String column, ColumnType desiredType) Create aColumnValueSelectorthat does its own typecasting if necessary. -
Uses of ColumnSelectorFactory in org.apache.druid.frame.write.columnar
Methods in org.apache.druid.frame.write.columnar with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionColumnarFrameWriterFactory.newFrameWriter(ColumnSelectorFactory columnSelectorFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation
Methods in org.apache.druid.query.aggregation with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionabstract AggregatorAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) ExpressionLambdaAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory) GroupingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory) final AggregatorNullableNumericAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory) protected abstract AggregatorNullableNumericAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory, T selector) Creates anAggregatorto aggregate values from several rows, by using the provided selector.protected AggregatorSimpleDoubleAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) protected AggregatorSimpleFloatAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) protected AggregatorSimpleLongAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) SingleValueAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) SuppressedAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) static AggregatorAdaptersAggregatorAdapters.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory, List<AggregatorFactory> aggregatorFactories) Create an adapters object based onBufferAggregator.abstract BufferAggregatorAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) CountAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) ExpressionLambdaAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FilteredAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) GroupingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) HistogramAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) JavaScriptAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) final BufferAggregatorNullableNumericAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) protected abstract BufferAggregatorNullableNumericAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory, T selector) Creates anBufferAggregatorto aggregate values from several rows into a ByteBuffer.protected BufferAggregatorSimpleDoubleAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) protected BufferAggregatorSimpleFloatAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) protected BufferAggregatorSimpleLongAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) SingleValueAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) SuppressedAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) AggregatorFactory.factorizeWithSize(ColumnSelectorFactory metricFactory) Creates anAggregatorbased on the provided column selector factory.protected abstract TNullableNumericAggregatorFactory.selector(ColumnSelectorFactory columnSelectorFactory) Creates aColumnValueSelectorfor the aggregated column.protected ColumnValueSelectorSimpleDoubleAggregatorFactory.selector(ColumnSelectorFactory metricFactory) protected ColumnValueSelectorSimpleFloatAggregatorFactory.selector(ColumnSelectorFactory metricFactory) protected ColumnValueSelectorSimpleLongAggregatorFactory.selector(ColumnSelectorFactory metricFactory) static booleanAggregatorUtil.shouldUseObjectColumnAggregatorWrapper(String fieldName, ColumnSelectorFactory columnSelectorFactory) Whether a simple numeric aggregator should useBaseObjectColumnValueSelector.getObject(), and coerce the result to number, rather than using a primitive method likeBaseLongColumnValueSelector.getLong().protected booleanNullableNumericAggregatorFactory.useGetObject(ColumnSelectorFactory columnSelectorFactory) Returns whether the selector created byNullableNumericAggregatorFactory.selector(ColumnSelectorFactory)for the givenColumnSelectorFactoryprefersBaseObjectColumnValueSelector.getObject().protected booleanSimpleDoubleAggregatorFactory.useGetObject(ColumnSelectorFactory columnSelectorFactory) protected booleanSimpleFloatAggregatorFactory.useGetObject(ColumnSelectorFactory columnSelectorFactory) protected booleanSimpleLongAggregatorFactory.useGetObject(ColumnSelectorFactory columnSelectorFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.any
Methods in org.apache.druid.query.aggregation.any with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionDoubleAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) FloatAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) LongAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) StringAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) DoubleAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FloatAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) LongAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) StringAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.cardinality
Methods in org.apache.druid.query.aggregation.cardinality with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionCardinalityAggregatorFactory.factorize(ColumnSelectorFactory columnFactory) CardinalityAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.firstlast.first
Methods in org.apache.druid.query.aggregation.firstlast.first with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionDoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) FloatFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) LongFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) StringFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) DoubleFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FloatFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) LongFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) StringFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.firstlast.last
Methods in org.apache.druid.query.aggregation.firstlast.last with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionDoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) FloatLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) LongLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) StringLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) DoubleLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FloatLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) LongLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) StringLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.hyperloglog
Methods in org.apache.druid.query.aggregation.hyperloglog with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionHyperUniquesAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) HyperUniquesAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.aggregation.mean
Methods in org.apache.druid.query.aggregation.mean with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionDoubleMeanAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) DoubleMeanAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of ColumnSelectorFactory in org.apache.druid.query.filter
Methods in org.apache.druid.query.filter with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionArrayContainsElementFilter.makeMatcher(ColumnSelectorFactory factory) EqualityFilter.makeMatcher(ColumnSelectorFactory factory) Filter.makeMatcher(ColumnSelectorFactory factory) Get aValueMatcherthat applies this filter to row values.InDimFilter.makeMatcher(ColumnSelectorFactory factory) NullFilter.makeMatcher(ColumnSelectorFactory factory) RangeFilter.makeMatcher(ColumnSelectorFactory factory) TypedInFilter.makeMatcher(ColumnSelectorFactory factory) FilterBundle.MatcherBundle.valueMatcher(ColumnSelectorFactory selectorFactory, Offset baseOffset, boolean descending) FilterBundle.SimpleMatcherBundle.valueMatcher(ColumnSelectorFactory selectorFactory, Offset baseOffset, boolean descending) Constructor parameters in org.apache.druid.query.filter with type arguments of type ColumnSelectorFactoryModifierConstructorDescriptionSimpleMatcherBundle(FilterBundle.MatcherBundleInfo matcherInfo, Function<ColumnSelectorFactory, ValueMatcher> matcherFn, Function<VectorColumnSelectorFactory, VectorValueMatcher> vectorMatcherFn, boolean canVectorize) -
Uses of ColumnSelectorFactory in org.apache.druid.query.groupby.epinephelinae
Methods in org.apache.druid.query.groupby.epinephelinae that return ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic ColumnSelectorFactoryRowBasedGrouperHelper.createResultRowBasedColumnSelectorFactory(GroupByQuery query, com.google.common.base.Supplier<ResultRow> supplier, RowSignature.Finalization finalization) Creates aColumnSelectorFactorythat can read rows which originate as results of the provided "query".Methods in org.apache.druid.query.groupby.epinephelinae with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic booleanGroupByQueryEngine.canPushDownLimit(ColumnSelectorFactory columnSelectorFactory, String columnName) check if a column will operate correctly withLimitedBufferHashGrouperfor query limit pushdownConstructors in org.apache.druid.query.groupby.epinephelinae with parameters of type ColumnSelectorFactoryModifierConstructorDescriptionConcurrentGrouper(GroupByQueryConfig groupByQueryConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, int concurrencyHint, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, com.google.common.util.concurrent.ListeningExecutorService executor, int priority, boolean hasQueryTimeout, long queryTimeoutAt, GroupByStatsProvider.PerQueryStats perQueryStats) SpillingGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float bufferGrouperMaxLoadFactor, int bufferGrouperInitialBuckets, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, boolean spillingAllowed, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats) -
Uses of ColumnSelectorFactory in org.apache.druid.query.rowsandcols.semantic
Classes in org.apache.druid.query.rowsandcols.semantic that implement ColumnSelectorFactoryModifier and TypeClassDescriptionstatic classMethods in org.apache.druid.query.rowsandcols.semantic that return ColumnSelectorFactoryModifier and TypeMethodDescriptionColumnSelectorFactoryMaker.make(AtomicInteger rowIdProvider) DefaultColumnSelectorFactoryMaker.make(AtomicInteger rowIdProvider) -
Uses of ColumnSelectorFactory in org.apache.druid.query.scan
Classes in org.apache.druid.query.scan that implement ColumnSelectorFactoryModifier and TypeClassDescriptionclassA column selector factory, that represents the column values from multiple underlying cursors. -
Uses of ColumnSelectorFactory in org.apache.druid.segment
Classes in org.apache.druid.segment that implement ColumnSelectorFactoryModifier and TypeClassDescriptionclassThe basic implementation ofColumnSelectorFactoryover a historical segment (i.classclassAColumnSelectorFactorythat is based on an object supplier and aRowAdapterfor that type of object.Methods in org.apache.druid.segment that return ColumnSelectorFactoryModifier and TypeMethodDescriptionCursor.getColumnSelectorFactory()Get aColumnSelectorFactorywhose selectors will be backed by the row values at the current position of the cursorRowBasedCursor.getColumnSelectorFactory()UnnestColumnValueSelectorCursor.getColumnSelectorFactory()UnnestDimensionCursor.getColumnSelectorFactory()protected ColumnSelectorFactoryQueryableIndexCursorHolder.makeColumnSelectorFactoryForOffset(ColumnCache columnCache, Offset baseOffset) VirtualColumns.wrap(ColumnSelectorFactory baseFactory) Creates aVirtualizedColumnSelectorFactorywhich can create column selectors forVirtualColumns.virtualColumnsin addition to selectors for all physical columns in the underlying factory.Methods in org.apache.druid.segment with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic <Strategy extends ColumnSelectorStrategy>
ColumnSelectorPlus<Strategy> DimensionHandlerUtils.createColumnSelectorPlus(ColumnSelectorStrategyFactory<Strategy> strategyFactory, DimensionSpec dimensionSpec, ColumnSelectorFactory cursor) Convenience function equivalent to callingDimensionHandlerUtils.createColumnSelectorPluses(ColumnSelectorStrategyFactory, List, ColumnSelectorFactory)with a singleton list of dimensionSpecs and then retrieving the only element in the returned array.static <Strategy extends ColumnSelectorStrategy>
ColumnSelectorPlus<Strategy>[]DimensionHandlerUtils.createColumnSelectorPluses(ColumnSelectorStrategyFactory<Strategy> strategyFactory, List<DimensionSpec> dimensionSpecs, ColumnSelectorFactory columnSelectorFactory) Creates an array of ColumnSelectorPlus objects, selectors that handle type-specific operations within query processing engines, using a strategy factory provided by the query engine.default ColumnValueSelector<?> VirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) Deprecated.default ColumnValueSelector<?> VirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory columnSelectorFactory, ColumnSelector columnSelector, ReadableOffset offset) Builds a selector corresponding to this virtual column.VirtualColumns.makeColumnValueSelector(String columnName, ColumnSelectorFactory selectorFactory, ColumnSelector columnSelector, ReadableOffset offset) Create a column value selector.default DimensionSelectorVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) default DimensionSelectorVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory columnSelectorFactory, ColumnSelector columnSelector, ReadableOffset offset) Build a selector corresponding to this virtual column.VirtualColumns.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory selectorFactory, ColumnSelector columnSelector, ReadableOffset offset) Create a dimension (string) selector.static <T> TColumnProcessors.makeProcessor(String column, ColumnProcessorFactory<T> processorFactory, ColumnSelectorFactory selectorFactory) Make a processor for a particular named column.static <T> TColumnProcessors.makeProcessor(Expr expr, ColumnType exprTypeHint, ColumnProcessorFactory<T> processorFactory, ColumnSelectorFactory selectorFactory) Make a processor for a particular expression.static <T> TColumnProcessors.makeProcessor(DimensionSpec dimensionSpec, ColumnProcessorFactory<T> processorFactory, ColumnSelectorFactory selectorFactory) Make a processor for a particularDimensionSpec.VirtualColumns.wrap(ColumnSelectorFactory baseFactory) Creates aVirtualizedColumnSelectorFactorywhich can create column selectors forVirtualColumns.virtualColumnsin addition to selectors for all physical columns in the underlying factory.Constructors in org.apache.druid.segment with parameters of type ColumnSelectorFactoryModifierConstructorDescriptionRemapColumnSelectorFactory(ColumnSelectorFactory delegate, Map<String, String> remap) UnnestColumnValueSelectorCursor(Cursor cursor, ColumnSelectorFactory baseColumnSelectorFactory, VirtualColumn unnestColumn) UnnestDimensionCursor(Cursor cursor, ColumnSelectorFactory baseColumnSelectorFactory, VirtualColumn unnestColumn) -
Uses of ColumnSelectorFactory in org.apache.druid.segment.filter
Methods in org.apache.druid.segment.filter with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionAndFilter.makeMatcher(ColumnSelectorFactory factory) BoundFilter.makeMatcher(ColumnSelectorFactory factory) ColumnComparisonFilter.makeMatcher(ColumnSelectorFactory factory) DimensionPredicateFilter.makeMatcher(ColumnSelectorFactory factory) ExpressionFilter.makeMatcher(ColumnSelectorFactory factory) FalseFilter.makeMatcher(ColumnSelectorFactory factory) IsBooleanFilter.makeMatcher(ColumnSelectorFactory factory) JavaScriptFilter.makeMatcher(ColumnSelectorFactory factory) LikeFilter.makeMatcher(ColumnSelectorFactory factory) NotFilter.makeMatcher(ColumnSelectorFactory factory) OrFilter.makeMatcher(ColumnSelectorFactory factory) SelectorFilter.makeMatcher(ColumnSelectorFactory factory) SpatialFilter.makeMatcher(ColumnSelectorFactory factory) TrueFilter.makeMatcher(ColumnSelectorFactory factory) static ValueMatcherFilters.makeValueMatcher(ColumnSelectorFactory columnSelectorFactory, String columnName, DruidPredicateFactory predicateFactory) Create a ValueMatcher that applies a predicate to row values. -
Uses of ColumnSelectorFactory in org.apache.druid.segment.incremental
Methods in org.apache.druid.segment.incremental that return ColumnSelectorFactoryModifier and TypeMethodDescriptionprotected ColumnSelectorFactoryIncrementalIndex.makeColumnSelectorFactory(AggregatorFactory agg, IncrementalIndex.InputRowHolder in) static ColumnSelectorFactoryIncrementalIndex.makeColumnSelectorFactory(VirtualColumns virtualColumns, IncrementalIndex.InputRowHolder inputRowHolder, AggregatorFactory agg) Column selector used at ingestion time for inputs to aggregators.IncrementalIndexCursorHolder.makeSelectorFactory(CursorBuildSpec buildSpec, IncrementalIndexRowHolder currEntry) -
Uses of ColumnSelectorFactory in org.apache.druid.segment.join
Methods in org.apache.druid.segment.join that return ColumnSelectorFactoryModifier and TypeMethodDescriptionJoinMatcher.getColumnSelectorFactory()Returns a factory for reading columns from theJoinablethat correspond to matched rows.PostJoinCursor.getColumnSelectorFactory()Methods in org.apache.druid.segment.join with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionJoinable.makeJoinMatcher(ColumnSelectorFactory leftColumnSelectorFactory, JoinConditionAnalysis condition, boolean remainderNeeded, Closer closer) Creates a JoinMatcher that can be used to implement a join onto this Joinable. -
Uses of ColumnSelectorFactory in org.apache.druid.segment.join.filter
Classes in org.apache.druid.segment.join.filter that implement ColumnSelectorFactory -
Uses of ColumnSelectorFactory in org.apache.druid.segment.join.lookup
Classes in org.apache.druid.segment.join.lookup that implement ColumnSelectorFactoryMethods in org.apache.druid.segment.join.lookup that return ColumnSelectorFactoryMethods in org.apache.druid.segment.join.lookup with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic LookupJoinMatcherLookupJoinMatcher.create(LookupExtractor extractor, ColumnSelectorFactory leftSelectorFactory, JoinConditionAnalysis condition, boolean remainderNeeded) LookupJoinable.makeJoinMatcher(ColumnSelectorFactory leftSelectorFactory, JoinConditionAnalysis condition, boolean remainderNeeded, Closer closer) -
Uses of ColumnSelectorFactory in org.apache.druid.segment.join.table
Classes in org.apache.druid.segment.join.table that implement ColumnSelectorFactoryMethods in org.apache.druid.segment.join.table that return ColumnSelectorFactoryModifier and TypeMethodDescriptionIndexedTableJoinMatcher.getColumnSelectorFactory()BroadcastSegmentIndexedTable.makeColumnSelectorFactory(ReadableOffset offset, Closer closer) default ColumnSelectorFactoryIndexedTable.makeColumnSelectorFactory(ReadableOffset offset, Closer closer) This method allows a table to directly provide an optimizedColumnSelectorFactoryforIndexedTableJoinMatcherto create selectors.Methods in org.apache.druid.segment.join.table with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionIndexedTableJoinable.makeJoinMatcher(ColumnSelectorFactory leftColumnSelectorFactory, JoinConditionAnalysis condition, boolean remainderNeeded, Closer closer) -
Uses of ColumnSelectorFactory in org.apache.druid.segment.nested
Methods in org.apache.druid.segment.nested with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionCompressedNestedDataComplexColumn.makeColumnValueSelector(List<NestedPathPart> path, ColumnSelectorFactory selectorFactory, ReadableOffset readableOffset) Create a selector for a nested path.NestedColumnSelectorFactory.makeColumnValueSelector(List<NestedPathPart> path, ColumnSelectorFactory columnSelectorFactory, ReadableOffset readableOffset) Make aColumnValueSelectorfor a nested column.CompressedNestedDataComplexColumn.makeDimensionSelector(List<NestedPathPart> path, ExtractionFn extractionFn, ColumnSelectorFactory selectorFactory, ReadableOffset readableOffset) Create a selector for a nested path.NestedColumnSelectorFactory.makeDimensionSelector(List<NestedPathPart> path, ExtractionFn extractionFn, ColumnSelectorFactory columnSelectorFactory, ReadableOffset readableOffset) Make aDimensionSelectorfor a nested column. -
Uses of ColumnSelectorFactory in org.apache.druid.segment.projections
Methods in org.apache.druid.segment.projections that return ColumnSelectorFactoryModifier and TypeMethodDescriptionQueryableProjection.wrapColumnSelectorFactory(ColumnSelectorFactory selectorFactory) The projection can contain pre-computed virtual columns or pre-aggregated aggregation columns.Methods in org.apache.druid.segment.projections with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionQueryableProjection.wrapColumnSelectorFactory(ColumnSelectorFactory selectorFactory) The projection can contain pre-computed virtual columns or pre-aggregated aggregation columns. -
Uses of ColumnSelectorFactory in org.apache.druid.segment.shim
Classes in org.apache.druid.segment.shim that implement ColumnSelectorFactoryMethods in org.apache.druid.segment.shim that return ColumnSelectorFactory -
Uses of ColumnSelectorFactory in org.apache.druid.segment.virtual
Classes in org.apache.druid.segment.virtual that implement ColumnSelectorFactoryModifier and TypeClassDescriptionclassColumnSelectorFactorywhich can create selectors for both virtual and non-virtual columnsMethods in org.apache.druid.segment.virtual with parameters of type ColumnSelectorFactoryModifier and TypeMethodDescriptionstatic Expr.ObjectBindingExpressionSelectors.createBindings(ColumnSelectorFactory columnSelectorFactory, ExpressionPlan plan) CreateExpr.ObjectBindinggiven aColumnSelectorFactoryandExpressionPlanwhich provides the set of identifiers which need a binding (list of required columns), and context of whether or not they are used as array or scalar inputsstatic ColumnValueSelectorExpressionSelectors.makeColumnValueSelector(ColumnSelectorFactory columnSelectorFactory, Expr expression) Makes a ColumnValueSelector whose getObject method returns an Object that is the value computed by anExprEval.ExpressionVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) FallbackVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) ListFilteredVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) NestedFieldVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory selectorFactory, ColumnSelector columnSelector, ReadableOffset offset) PrefixFilteredVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) RegexFilteredVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory factory) SpecializedExpressionVirtualColumn.makeColumnValueSelector(String columnName, ColumnSelectorFactory columnSelectorFactory, ColumnSelector columnSelector, ReadableOffset offset) static DimensionSelectorExpressionSelectors.makeDimensionSelector(ColumnSelectorFactory columnSelectorFactory, Expr expression, ExtractionFn extractionFn) Makes a single or multi-valueDimensionSelectorwrapper around aColumnValueSelectorcreated byExpressionSelectors.makeExprEvalSelector(ColumnSelectorFactory, Expr)as appropriateExpressionVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory columnSelectorFactory) FallbackVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) ListFilteredVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) NestedFieldVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory selectorFactory, ColumnSelector columnSelector, ReadableOffset offset) PrefixFilteredVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) RegexFilteredVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory factory) SpecializedExpressionVirtualColumn.makeDimensionSelector(DimensionSpec dimensionSpec, ColumnSelectorFactory columnSelectorFactory, ColumnSelector columnSelector, ReadableOffset offset) static ColumnValueSelector<ExprEval> ExpressionSelectors.makeExprEvalSelector(ColumnSelectorFactory columnSelectorFactory, Expr expression) Makes a ColumnValueSelector whose getObject method returns anExprEval.static ColumnValueSelectorExpressionSelectors.makeStringColumnValueSelector(ColumnSelectorFactory columnSelectorFactory, Expr expression) Constructors in org.apache.druid.segment.virtual with parameters of type ColumnSelectorFactoryModifierConstructorDescriptionVirtualizedColumnSelectorFactory(ColumnSelectorFactory baseFactory, VirtualColumns virtualColumns)
VirtualColumn.makeColumnValueSelector(String, ColumnSelectorFactory, ColumnSelector, ReadableOffset)