Uses of Interface
org.apache.druid.query.rowsandcols.RowsAndColumns

Packages that use RowsAndColumns

Package	Description
org.apache.druid.frame.channel
org.apache.druid.frame.file
org.apache.druid.frame.wire
org.apache.druid.query.operator
org.apache.druid.query.operator.window
org.apache.druid.query.operator.window.ranking
org.apache.druid.query.operator.window.value
org.apache.druid.query.rowsandcols
org.apache.druid.query.rowsandcols.concrete
org.apache.druid.query.rowsandcols.semantic
org.apache.druid.query.rowsandcols.serde

Uses of RowsAndColumns in org.apache.druid.frame.channel

Methods in org.apache.druid.frame.channel that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	FrameChannelSequence.FrameChannelIterator.next()
RowsAndColumns	ComposingReadableFrameChannel.read()
RowsAndColumns	ReadableByteChunksFrameChannel.read()
RowsAndColumns	ReadableConcatFrameChannel.read()
RowsAndColumns	ReadableFileFrameChannel.read()
RowsAndColumns	ReadableFrameChannel.read()	Returns the next available batch of data from this channel as a RowsAndColumns.
RowsAndColumns	ReadableInputStreamFrameChannel.read()
RowsAndColumns	ReadableNilFrameChannel.read()

Methods in org.apache.druid.frame.channel with parameters of type RowsAndColumns

Modifier and Type	Method	Description
void	ComposingWritableFrameChannel.write(RowsAndColumns rac, int partitionNum)
default void	WritableFrameChannel.write(RowsAndColumns rac)	Writes a batch of data without an attached partition number.
void	WritableFrameChannel.write(RowsAndColumns rac, int partitionNumber)	Writes a batch of data with an attached partition number.
void	WritableFrameFileChannel.write(RowsAndColumns rac, int partitionNumber)

Uses of RowsAndColumns in org.apache.druid.frame.file

Methods in org.apache.druid.frame.file that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	FrameFile.rac(int batchNumber, WireTransferable.ConcreteDeserializer deserializer)	Reads a RowsAndColumns from the file.

Methods in org.apache.druid.frame.file with parameters of type RowsAndColumns

Modifier and Type	Method	Description
void	FrameFileWriter.write(RowsAndColumns rac, int partition)	Write a batch of data to the file.

Uses of RowsAndColumns in org.apache.druid.frame.wire

Methods in org.apache.druid.frame.wire that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	FrameWireTransferable.Deserializer.deserialize(com.fasterxml.jackson.databind.ObjectMapper mapper, ByteBuffer theBytes)

Uses of RowsAndColumns in org.apache.druid.query.operator

Fields in org.apache.druid.query.operator with type parameters of type RowsAndColumns

Modifier and Type	Field	Description
protected final AtomicReference<Iterator<RowsAndColumns>>	AbstractPartitioningOperator.AbstractReceiver.iterHolder

Methods in org.apache.druid.query.operator that return types with arguments of type RowsAndColumns

Modifier and Type	Method	Description
QueryRunner<RowsAndColumns>	WindowOperatorQueryQueryRunnerFactory.createRunner(Segment segment)
protected abstract Iterator<RowsAndColumns>	AbstractPartitioningOperator.AbstractReceiver.getIteratorForRAC(RowsAndColumns rac)
com.fasterxml.jackson.core.type.TypeReference<RowsAndColumns>	WindowOperatorQueryQueryToolChest.getResultTypeReference()
QueryToolChest<RowsAndColumns,WindowOperatorQuery>	WindowOperatorQueryQueryRunnerFactory.getToolchest()
com.google.common.base.Function<RowsAndColumns,RowsAndColumns>	WindowOperatorQueryQueryToolChest.makePreComputeManipulatorFn(WindowOperatorQuery query, MetricManipulationFn fn)
com.google.common.base.Function<RowsAndColumns,RowsAndColumns>	WindowOperatorQueryQueryToolChest.makePreComputeManipulatorFn(WindowOperatorQuery query, MetricManipulationFn fn)
QueryRunner<RowsAndColumns>	WindowOperatorQueryQueryToolChest.mergeResults(QueryRunner<RowsAndColumns> runner)
QueryRunner<RowsAndColumns>	WindowOperatorQueryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<RowsAndColumns>> queryRunners)
Query<RowsAndColumns>	WindowOperatorQuery.withDataSource(DataSource dataSource)
Query<RowsAndColumns>	WindowOperatorQuery.withOperators(List<OperatorFactory> operators)
Query<RowsAndColumns>	WindowOperatorQuery.withOverriddenContext(Map<String,Object> contextOverride)
Query<RowsAndColumns>	WindowOperatorQuery.withQuerySegmentSpec(QuerySegmentSpec spec)

Methods in org.apache.druid.query.operator with parameters of type RowsAndColumns

Modifier and Type	Method	Description
protected abstract Iterator<RowsAndColumns>	AbstractPartitioningOperator.AbstractReceiver.getIteratorForRAC(RowsAndColumns rac)
Operator.Signal	AbstractPartitioningOperator.AbstractReceiver.push(RowsAndColumns rac)
Operator.Signal	Operator.Receiver.push(RowsAndColumns rac)	Used to push data.
protected Operator.Signal	AbstractPartitioningOperator.AbstractReceiver.pushPartition(RowsAndColumns partition, boolean isLastPartition, Operator.Signal previousSignal)

Method parameters in org.apache.druid.query.operator with type arguments of type RowsAndColumns

Modifier and Type	Method	Description
<OutType> OutType	OperatorSequence.accumulate(OutType initValue, Accumulator<OutType,RowsAndColumns> accumulator)
protected abstract Operator.Receiver	AbstractPartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
protected Operator.Receiver	GlueingPartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
protected Operator.Receiver	NaivePartitioningOperator.createReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder)
protected AbstractPartitioningOperator.HandleContinuationResult	AbstractPartitioningOperator.handleNonGoCases(Operator.Signal signal, Iterator<RowsAndColumns> iter, Operator.Receiver receiver, AbstractPartitioningOperator.Continuation cont)
QueryRunner<RowsAndColumns>	WindowOperatorQueryQueryToolChest.mergeResults(QueryRunner<RowsAndColumns> runner)
QueryRunner<RowsAndColumns>	WindowOperatorQueryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<RowsAndColumns>> queryRunners)
Sequence<Object[]>	WindowOperatorQueryQueryToolChest.resultsAsArrays(WindowOperatorQuery query, Sequence<RowsAndColumns> resultSequence)
Optional<Sequence<FrameSignaturePair>>	WindowOperatorQueryQueryToolChest.resultsAsFrames(WindowOperatorQuery query, Sequence<RowsAndColumns> resultSequence, MemoryAllocatorFactory memoryAllocatorFactory, boolean useNestedForUnknownTypes)
<OutType> Yielder<OutType>	OperatorSequence.toYielder(OutType initValue, YieldingAccumulator<OutType,RowsAndColumns> accumulator)

Constructor parameters in org.apache.druid.query.operator with type arguments of type RowsAndColumns

Modifier	Constructor	Description
	AbstractReceiver(Operator.Receiver delegate, AtomicReference<Iterator<RowsAndColumns>> iterHolder, List<String> partitionColumns)
	Continuation(Iterator<RowsAndColumns> iter, Closeable subContinuation)
	SequenceOperator(Sequence<RowsAndColumns> child)

Uses of RowsAndColumns in org.apache.druid.query.operator.window

Methods in org.apache.druid.query.operator.window that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	ComposingProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	Processor.process(RowsAndColumns incomingPartition)	Applies the logic of the processor to a RowsAndColumns object
RowsAndColumns	WindowFramedAggregateProcessor.process(RowsAndColumns inputPartition)

Methods in org.apache.druid.query.operator.window with parameters of type RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	ComposingProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	Processor.process(RowsAndColumns incomingPartition)	Applies the logic of the processor to a RowsAndColumns object
RowsAndColumns	WindowFramedAggregateProcessor.process(RowsAndColumns inputPartition)

Uses of RowsAndColumns in org.apache.druid.query.operator.window.ranking

Methods in org.apache.druid.query.operator.window.ranking that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	WindowCumeDistProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowDenseRankProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowPercentileProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowRankProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowRowNumberProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowRankingProcessorBase.processInternal(RowsAndColumns incomingPartition, Function<int[],Column> fn)

Methods in org.apache.druid.query.operator.window.ranking with parameters of type RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	WindowCumeDistProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowDenseRankProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowPercentileProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowRankProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowRowNumberProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowRankingProcessorBase.processInternal(RowsAndColumns incomingPartition, Function<int[],Column> fn)

Uses of RowsAndColumns in org.apache.druid.query.operator.window.value

Methods in org.apache.druid.query.operator.window.value that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	WindowFirstProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowLastProcessor.process(RowsAndColumns input)
RowsAndColumns	WindowOffsetProcessor.process(RowsAndColumns input)
RowsAndColumns	WindowValueProcessorBase.processInternal(RowsAndColumns input, Function<Column,Column> fn)	This implements the common logic between the various value processors.

Methods in org.apache.druid.query.operator.window.value with parameters of type RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	WindowFirstProcessor.process(RowsAndColumns incomingPartition)
RowsAndColumns	WindowLastProcessor.process(RowsAndColumns input)
RowsAndColumns	WindowOffsetProcessor.process(RowsAndColumns input)
RowsAndColumns	WindowValueProcessorBase.processInternal(RowsAndColumns input, Function<Column,Column> fn)	This implements the common logic between the various value processors.

Uses of RowsAndColumns in org.apache.druid.query.rowsandcols

Classes in org.apache.druid.query.rowsandcols that implement RowsAndColumns

Modifier and Type	Class	Description
class	AppendableMapOfColumns
class	ArrayListRowsAndColumns<RowType>	ArrayListRowsAndColumns is a RowsAndColumns implementation that believes it has all of its data on-heap.
class	ConcatRowsAndColumns	A RowsAndColumns implementation that effectively concatenates multiple RowsAndColumns objects together.
class	CursorFactoryRowsAndColumns	Provides RowsAndColumns on top of a CursorFactory.
class	EmptyRowsAndColumns
class	LazilyDecoratedRowsAndColumns
class	LimitedRowsAndColumns
class	MapOfColumnsRowsAndColumns
class	RearrangedRowsAndColumns	This class exists to "decorate" a rows and columns such that it pretends to exist in a new ordering.

Methods in org.apache.druid.query.rowsandcols that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	LazilyDecoratedRowsAndColumns.getBase()

Methods in org.apache.druid.query.rowsandcols with parameters of type RowsAndColumns

Modifier and Type	Method	Description
static AppendableRowsAndColumns	RowsAndColumns.expectAppendable(RowsAndColumns input)

Constructors in org.apache.druid.query.rowsandcols with parameters of type RowsAndColumns

Modifier	Constructor	Description
	AppendableMapOfColumns(RowsAndColumns base)
	LazilyDecoratedRowsAndColumns(RowsAndColumns base, org.joda.time.Interval interval, Filter filter, VirtualColumns virtualColumns, OffsetLimit limit, List<ColumnWithDirection> ordering, LinkedHashSet<String> viewableColumns, Long allocatorCapacity)
	LimitedRowsAndColumns(RowsAndColumns rac, int start, int end)
	RearrangedRowsAndColumns(int[] pointers, int start, int end, RowsAndColumns rac)
	RearrangedRowsAndColumns(int[] pointers, RowsAndColumns rac)

Constructor parameters in org.apache.druid.query.rowsandcols with type arguments of type RowsAndColumns

Modifier	Constructor	Description
	ConcatRowsAndColumns(ArrayList<RowsAndColumns> racBuffer)

Uses of RowsAndColumns in org.apache.druid.query.rowsandcols.concrete

Subinterfaces of RowsAndColumns in org.apache.druid.query.rowsandcols.concrete

Modifier and Type	Interface	Description
interface	FrameRowsAndColumns	Wrapper around Frame with an optional signature (see FrameRowsAndColumns.getSignature()).

Classes in org.apache.druid.query.rowsandcols.concrete that implement RowsAndColumns

Modifier and Type	Class	Description
class	AbstractFrameRowsAndColumns
class	ColumnBasedFrameRowsAndColumns
class	QueryableIndexRowsAndColumns
class	RowBasedFrameRowsAndColumns

Uses of RowsAndColumns in org.apache.druid.query.rowsandcols.semantic

Subinterfaces of RowsAndColumns in org.apache.druid.query.rowsandcols.semantic

Modifier and Type	Interface	Description
interface	AppendableRowsAndColumns	A RowsAndColumns that supports appending columns.

Methods in org.apache.druid.query.rowsandcols.semantic that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	DefaultFramedOnHeapAggregatable.aggregateAll(WindowFrame frame, AggregatorFactory[] aggFactories)
RowsAndColumns	FramedOnHeapAggregatable.aggregateAll(WindowFrame frame, AggregatorFactory[] aggFactories)	Aggregates the data according to the WindowFrame using the AggregatorFactory objects provided.
RowsAndColumns	NaiveSortMaker.NaiveSorter.complete()	Indicate that there is no more data coming.
RowsAndColumns	WireTransferable.ConcreteDeserializer.deserialize(ByteBuffer theBytes)	Deserializes a ByteBuffer into a RowsAndColumns.
RowsAndColumns	WireTransferable.Deserializer.deserialize(com.fasterxml.jackson.databind.ObjectMapper mapper, ByteBuffer theBytes)	Deserializes a ByteBuffer into a RowsAndColumns.
RowsAndColumns	NaiveSortMaker.NaiveSorter.moreData(RowsAndColumns rac)	Adds more data to the sort.
RowsAndColumns	DefaultRowsAndColumnsDecorator.restrictColumns(List<String> columns)
RowsAndColumns	RowsAndColumnsDecorator.restrictColumns(List<String> columns)
RowsAndColumns	DefaultRowsAndColumnsDecorator.toRowsAndColumns()
RowsAndColumns	RowsAndColumnsDecorator.toRowsAndColumns()

Methods in org.apache.druid.query.rowsandcols.semantic that return types with arguments of type RowsAndColumns

Modifier and Type	Method	Description
ArrayList<RowsAndColumns>	ClusteredGroupPartitioner.partitionOnBoundaries(List<String> partitionColumns)	Semantically equivalent to computeBoundaries, but returns a list of RowsAndColumns objects instead of just boundary positions.
ArrayList<RowsAndColumns>	DefaultClusteredGroupPartitioner.partitionOnBoundaries(List<String> partitionColumns)

Methods in org.apache.druid.query.rowsandcols.semantic with parameters of type RowsAndColumns

Modifier and Type	Method	Description
static ClusteredGroupPartitioner	ClusteredGroupPartitioner.fromRAC(RowsAndColumns rac)
static ColumnSelectorFactoryMaker	ColumnSelectorFactoryMaker.fromRAC(RowsAndColumns rac)
static FramedOnHeapAggregatable	FramedOnHeapAggregatable.fromRAC(RowsAndColumns rac)
static FrameMaker	FrameMaker.fromRAC(RowsAndColumns rac)
static NaiveSortMaker	NaiveSortMaker.fromRAC(RowsAndColumns rac)
static RowsAndColumnsDecorator	RowsAndColumnsDecorator.fromRAC(RowsAndColumns rac)
static SortedMatrixMaker	SortedMatrixMaker.fromRAC(RowsAndColumns rac)
RowsAndColumns	NaiveSortMaker.NaiveSorter.moreData(RowsAndColumns rac)	Adds more data to the sort.

Constructors in org.apache.druid.query.rowsandcols.semantic with parameters of type RowsAndColumns

Modifier	Constructor	Description
	ColumnAccessorBasedColumnSelectorFactory(AtomicInteger cellIdSupplier, RowsAndColumns rac)
	DefaultClusteredGroupPartitioner(RowsAndColumns rac)
	DefaultColumnSelectorFactoryMaker(RowsAndColumns rac)
	DefaultFrameMaker(RowsAndColumns rac)
	DefaultGroupPartitioner(RowsAndColumns rac)
	DefaultNaiveSortMaker(RowsAndColumns rac)
	DefaultRowsAndColumnsDecorator(RowsAndColumns base)
	DefaultRowsAndColumnsDecorator(RowsAndColumns base, org.joda.time.Interval interval, Filter filter, VirtualColumns virtualColumns, OffsetLimit limit, List<ColumnWithDirection> ordering)
	DefaultSortedMatrixMaker(RowsAndColumns rac)

Uses of RowsAndColumns in org.apache.druid.query.rowsandcols.serde

Methods in org.apache.druid.query.rowsandcols.serde that return RowsAndColumns

Modifier and Type	Method	Description
RowsAndColumns	RowsAndColumnsDeserializer.deserialize(com.fasterxml.jackson.core.JsonParser jsonParser, com.fasterxml.jackson.databind.DeserializationContext deserializationContext)
RowsAndColumns	WireTransferableContext.deserialize(ByteBuffer theBytes)	Deserializes a ByteBuffer into a RowsAndColumns.

Methods in org.apache.druid.query.rowsandcols.serde with parameters of type RowsAndColumns

Modifier and Type	Method	Description
void	RowsAndColumnsSerializer.serialize(RowsAndColumns rac, com.fasterxml.jackson.core.JsonGenerator jsonGenerator, com.fasterxml.jackson.databind.SerializerProvider serializerProvider)