Uses of Interface
org.apache.druid.segment.Cursor
Packages that use Cursor
Package
Description
-
Uses of Cursor in org.apache.druid.frame.segment
Classes in org.apache.druid.frame.segment that implement CursorModifier and TypeClassDescriptionclassMethods in org.apache.druid.frame.segment with parameters of type CursorModifier and TypeMethodDescriptionFrameCursorUtils.cursorToFramesIterable(Cursor cursor, FrameWriterFactory frameWriterFactory) FrameCursorUtils.cursorToFramesSequence(Cursor cursor, FrameWriterFactory frameWriterFactory) -
Uses of Cursor in org.apache.druid.query
Methods in org.apache.druid.query that return types with arguments of type CursorModifier and TypeMethodDescriptionIterableRowsCursorHelper.getCursorFromIterable(Iterable<Object[]> rows, RowSignature rowSignature) Creates a cursor that iterates over all the rows generated by the iterable.IterableRowsCursorHelper.getCursorFromSequence(Sequence<Object[]> rows, RowSignature rowSignature) Creates a cursor that iterates over all the rows generated by the sequence.IterableRowsCursorHelper.getCursorFromYielder(Yielder<Object[]> yielderParam, RowSignature rowSignature) Methods in org.apache.druid.query with parameters of type CursorModifier and TypeMethodDescriptionstatic CursorGranularizerCursorGranularizer.create(Cursor cursor, TimeBoundaryInspector timeBoundaryInspector, Order timeOrder, Granularity granularity, org.joda.time.Interval queryInterval) -
Uses of Cursor in org.apache.druid.query.scan
Constructor parameters in org.apache.druid.query.scan with type arguments of type CursorModifierConstructorDescriptionSettableCursorColumnSelectorFactory(Supplier<Cursor> cursorSupplier, RowSignature rowSignature) -
Uses of Cursor in org.apache.druid.query.topn
Methods in org.apache.druid.query.topn that return CursorMethods in org.apache.druid.query.topn with parameters of type CursorModifier and TypeMethodDescriptionTopNMapFn.apply(Cursor cursor, ColumnSelectorPlus<TopNColumnAggregatesProcessor<?>> selectorPlus, CursorGranularizer granularizer, TopNQueryMetrics queryMetrics) voidvoidThis method is called exactly once with each cursor, processed for the query.static Aggregator[]BaseTopNAlgorithm.makeAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs) protected static BufferAggregator[]BaseTopNAlgorithm.makeBufferAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs) AggregateTopNMetricFirstAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus, Cursor cursor, CursorGranularizer granularizer) HeapBasedTopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnAggregatesProcessor> selectorPlus, Cursor cursor, CursorGranularizer granularizer) PooledTopNAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus, Cursor cursor, CursorGranularizer granularizer) TimeExtractionTopNAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus, Cursor cursor, CursorGranularizer granularizer) TopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnAggregatesProcessor> selectorPlus, Cursor cursor, CursorGranularizer granularizer) longGeneric1AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator, int aggregatorSize, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) longGeneric1AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator, int aggregatorSize, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) Any changes to this method should be coordinated withTopNUtils,PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations()and downstream methods.longGeneric2AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator1, int aggregator1Size, BufferAggregator aggregator2, int aggregator2Size, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) longGeneric2AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator1, int aggregator1Size, BufferAggregator aggregator2, int aggregator2Size, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) Any changes to this method should be coordinated withTopNUtils,PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations()and downstream methods.PooledTopNAlgorithm.PooledTopNParams.Builder.withCursor(Cursor cursor) Constructors in org.apache.druid.query.topn with parameters of type CursorModifierConstructorDescriptionPooledTopNParams(ColumnSelectorPlus selectorPlus, Cursor cursor, CursorGranularizer granularizer, ResourceHolder<ByteBuffer> resultsBufHolder, ByteBuffer resultsBuf, int[] aggregatorSizes, int numBytesPerRecord, int numValuesPerPass, TopNMetricSpecBuilder<int[]> arrayProvider) protectedTopNParams(ColumnSelectorPlus<TopNColumnAggregatesProcessor> selectorPlus, Cursor cursor, CursorGranularizer granularizer, int numValuesPerPass) -
Uses of Cursor in org.apache.druid.query.topn.types
Methods in org.apache.druid.query.topn.types with parameters of type CursorModifier and TypeMethodDescriptionlongNullableNumericTopNColumnAggregatesProcessor.scanAndAggregate(TopNQuery query, Selector selector, Cursor cursor, CursorGranularizer granularizer, Aggregator[][] rowSelector) longStringTopNColumnAggregatesProcessor.scanAndAggregate(TopNQuery query, DimensionSelector selector, Cursor cursor, CursorGranularizer granularizer, Aggregator[][] rowSelector) longTopNColumnAggregatesProcessor.scanAndAggregate(TopNQuery query, ValueSelectorType selector, Cursor cursor, CursorGranularizer granularizer, Aggregator[][] rowSelector) Used byHeapBasedTopNAlgorithm. -
Uses of Cursor in org.apache.druid.segment
Classes in org.apache.druid.segment that implement CursorModifier and TypeClassDescriptionclassRowBasedCursor<RowType>ACursorthat is based on a stream of objects.classThe cursor to help unnest MVDs without dictionary encoding and ARRAY type selectors.classThe cursor to help unnest MVDs with dictionary encoding.Methods in org.apache.druid.segment that return CursorModifier and TypeMethodDescriptionCursorHolder.asCursor()Create aCursorfor use with non-vectorized query engines.QueryableIndexCursorHolder.asCursor()Constructors in org.apache.druid.segment with parameters of type CursorModifierConstructorDescriptionUnnestColumnValueSelectorCursor(Cursor cursor, ColumnSelectorFactory baseColumnSelectorFactory, VirtualColumn unnestColumn) UnnestDimensionCursor(Cursor cursor, ColumnSelectorFactory baseColumnSelectorFactory, VirtualColumn unnestColumn) -
Uses of Cursor in org.apache.druid.segment.historical
Subinterfaces of Cursor in org.apache.druid.segment.historical -
Uses of Cursor in org.apache.druid.segment.incremental
Methods in org.apache.druid.segment.incremental that return Cursor -
Uses of Cursor in org.apache.druid.segment.join
Classes in org.apache.druid.segment.join that implement CursorModifier and TypeClassDescriptionclassA Cursor decorator used byHashJoinSegmentCursorFactory.makeCursorHolder(CursorBuildSpec)to add post-join virtual columns and filters.Methods in org.apache.druid.segment.join that return CursorModifier and TypeMethodDescriptionstatic CursorHashJoinEngine.makeJoinCursor(Cursor leftCursor, JoinableClause joinableClause, Closer closer) Creates a cursor that represents the join of with .Methods in org.apache.druid.segment.join with parameters of type CursorModifier and TypeMethodDescriptionstatic CursorHashJoinEngine.makeJoinCursor(Cursor leftCursor, JoinableClause joinableClause, Closer closer) Creates a cursor that represents the join of with .static PostJoinCursorPostJoinCursor.wrap(Cursor baseCursor, VirtualColumns virtualColumns, Filter filter) -
Uses of Cursor in org.apache.druid.segment.shim
Classes in org.apache.druid.segment.shim that implement Cursor