Package io.deephaven.engine.table.impl.sources.aggregate

Interface AggregateColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>,COMPONENT_TYPE>

All Superinterfaces:

ChunkSource<Values>, ChunkSource.WithPrev<Values>, ColumnSource<VECTOR_TYPE>, ColumnSourceGetDefaults.ForObject<VECTOR_TYPE>, ElementSource<VECTOR_TYPE>, FillContextMaker, GetContextMaker, MutableColumnSource<VECTOR_TYPE>, MutableColumnSourceGetDefaults.ForObject<VECTOR_TYPE>, Releasable, TupleExporter<VECTOR_TYPE>, TupleSource<VECTOR_TYPE>, UngroupableColumnSource

All Known Implementing Classes:

BaseAggregateSlicedColumnSource, ByteAggregateColumnSource, CharAggregateColumnSource, DoubleAggregateColumnSource, FloatAggregateColumnSource, IntAggregateColumnSource, LongAggregateColumnSource, ObjectAggregateColumnSource, RangeAggregateColumnSource, RangeAggregateColumnSourceByte, RangeAggregateColumnSourceChar, RangeAggregateColumnSourceDouble, RangeAggregateColumnSourceFloat, RangeAggregateColumnSourceInt, RangeAggregateColumnSourceLong, RangeAggregateColumnSourceObject, RangeAggregateColumnSourceShort, ShortAggregateColumnSource, SlicedByteAggregateColumnSource, SlicedCharAggregateColumnSource, SlicedDoubleAggregateColumnSource, SlicedFloatAggregateColumnSource, SlicedIntAggregateColumnSource, SlicedLongAggregateColumnSource, SlicedObjectAggregateColumnSource, SlicedShortAggregateColumnSource

public interface AggregateColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>,COMPONENT_TYPE>
extends UngroupableColumnSource, MutableColumnSourceGetDefaults.ForObject<VECTOR_TYPE>

ColumnSource and UngroupableColumnSource interface for aggregation result columns.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	AggregateColumnSource.FactoryHelper

Nested classes/interfaces inherited from interface io.deephaven.engine.table.ChunkSource

ChunkSource.FillContext, ChunkSource.GetContext, ChunkSource.WithPrev<ATTR extends Any>

Nested classes/interfaces inherited from interface io.deephaven.engine.table.TupleExporter

TupleExporter.ExportElementFunction<TUPLE_TYPE>

Field Summary

Fields inherited from interface io.deephaven.engine.table.ChunkSource

DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAY

Fields inherited from interface io.deephaven.engine.table.ChunkSource.WithPrev

ZERO_LENGTH_CHUNK_SOURCE_WITH_PREV_ARRAY

Fields inherited from interface io.deephaven.engine.table.ColumnSource

ZERO_LENGTH_COLUMN_SOURCE_ARRAY

Method Summary

Modifier and Type	Method	Description
static <VECTOR_TYPE extends Vector<VECTOR_TYPE>, DATA_TYPE> AggregateColumnSource<VECTOR_TYPE,DATA_TYPE>	forRangeJoin(@NotNull ColumnSource<?> aggregatedSource, @NotNull ColumnSource<? extends RowSet> groupRowSetSource, @NotNull ColumnSource<Integer> startPositionInclusiveSource, @NotNull ColumnSource<Integer> endPositionExclusiveSource)	Returns a range aggregated ColumnSource from the provided sources.
static <VECTOR_TYPE extends Vector<VECTOR_TYPE>, DATA_TYPE> AggregateColumnSource<VECTOR_TYPE,DATA_TYPE>	make(@NotNull ColumnSource<DATA_TYPE> aggregatedSource, @NotNull ColumnSource<? extends RowSet> groupRowSetSource)
static <VECTOR_TYPE extends Vector<VECTOR_TYPE>, DATA_TYPE> AggregateColumnSource<VECTOR_TYPE,DATA_TYPE>	makeSliced(@NotNull ColumnSource<DATA_TYPE> aggregatedSource, @NotNull ColumnSource<? extends RowSet> groupRowSetSource, long startPosOffset, long endPosOffset)	Returns a sliced aggregate ColumnSource from the provided sources.
static <VECTOR_TYPE extends Vector<VECTOR_TYPE>, DATA_TYPE> AggregateColumnSource<VECTOR_TYPE,DATA_TYPE>	makeSliced(@NotNull ColumnSource<DATA_TYPE> aggregatedSource, @NotNull ColumnSource<? extends RowSet> groupRowSetSource, @NotNull ColumnSource<Long> startPosSource, @NotNull ColumnSource<Long> endPosSource)	Returns a sliced aggregate ColumnSource from the provided sources.
UngroupedColumnSource<COMPONENT_TYPE>	ungrouped()

Methods inherited from interface io.deephaven.engine.table.ChunkSource

fillChunk, getChunk, getChunk

Methods inherited from interface io.deephaven.engine.table.ChunkSource.WithPrev

fillPrevChunk, getPrevChunk, getPrevChunk

Methods inherited from interface io.deephaven.engine.table.ColumnSource

allowsReinterpret, cast, cast, cast, cast, createPreviousTuple, createTuple, createTupleFromValues, exportAllTo, exportElement, exportElement, getChunkType, getComponentType, getPrevSource, getType, isStateless, match, reinterpret, releaseCachedResources, startTrackingPrevValues, tupleLength

Methods inherited from interface io.deephaven.engine.table.impl.ColumnSourceGetDefaults.ForObject

getBoolean, getByte, getChar, getDouble, getFloat, getInt, getLong, getShort

Methods inherited from interface io.deephaven.engine.table.ElementSource

get, getPrev

Methods inherited from interface io.deephaven.engine.table.FillContextMaker

makeFillContext, makeFillContext

Methods inherited from interface io.deephaven.engine.table.GetContextMaker

makeGetContext, makeGetContext

Methods inherited from interface io.deephaven.engine.table.impl.MutableColumnSource

isImmutable

Methods inherited from interface io.deephaven.engine.table.impl.MutableColumnSourceGetDefaults.ForObject

getPrevBoolean, getPrevByte, getPrevChar, getPrevDouble, getPrevFloat, getPrevInt, getPrevLong, getPrevShort

Methods inherited from interface io.deephaven.engine.table.TupleExporter

exportAllReinterpretedTo, exportAllReinterpretedTo, exportAllTo, exportElementReinterpreted

Methods inherited from interface io.deephaven.engine.table.TupleSource

createTupleFromReinterpretedValues

Methods inherited from interface io.deephaven.engine.table.impl.sources.UngroupableColumnSource

getUngrouped, getUngroupedBoolean, getUngroupedByte, getUngroupedChar, getUngroupedDouble, getUngroupedFloat, getUngroupedInt, getUngroupedLong, getUngroupedPrev, getUngroupedPrevBoolean, getUngroupedPrevByte, getUngroupedPrevChar, getUngroupedPrevDouble, getUngroupedPrevFloat, getUngroupedPrevInt, getUngroupedPrevLong, getUngroupedPrevShort, getUngroupedPrevSize, getUngroupedShort, getUngroupedSize, isUngroupable

Method Details

ungrouped

UngroupedColumnSource<COMPONENT_TYPE> ungrouped()

make

static <VECTOR_TYPE extends Vector<VECTOR_TYPE>,
DATA_TYPE>
AggregateColumnSource<VECTOR_TYPE,DATA_TYPE> make(@NotNull
 @NotNull ColumnSource<DATA_TYPE> aggregatedSource,
 @NotNull
 @NotNull ColumnSource<? extends RowSet> groupRowSetSource)

makeSliced

static <VECTOR_TYPE extends Vector<VECTOR_TYPE>,
DATA_TYPE>
AggregateColumnSource<VECTOR_TYPE,DATA_TYPE> makeSliced(@NotNull
 @NotNull ColumnSource<DATA_TYPE> aggregatedSource,
 @NotNull
 @NotNull ColumnSource<? extends RowSet> groupRowSetSource,
 @NotNull
 @NotNull ColumnSource<Long> startPosSource,
 @NotNull
 @NotNull ColumnSource<Long> endPosSource)

Returns a sliced aggregate ColumnSource from the provided sources.

Parameters:

aggregatedSource - the value column source for the aggregation

groupRowSetSource - the column source that maps rows to group row sets

startPosSource - the column source that maps rows to starting position offsets

endPosSource - the column source that maps rows to ending position offsets (exclusive)

makeSliced

static <VECTOR_TYPE extends Vector<VECTOR_TYPE>,
DATA_TYPE>
AggregateColumnSource<VECTOR_TYPE,DATA_TYPE> makeSliced(@NotNull
 @NotNull ColumnSource<DATA_TYPE> aggregatedSource,
 @NotNull
 @NotNull ColumnSource<? extends RowSet> groupRowSetSource,
 long startPosOffset,
 long endPosOffset)

Returns a sliced aggregate ColumnSource from the provided sources.

Parameters:

aggregatedSource - the value column source for the aggregation

groupRowSetSource - the column source that maps rows to group row sets

startPosOffset - the fixed starting position offset for every row

endPosOffset - the fixed ending position offset for every row (exclusive)

forRangeJoin

static <VECTOR_TYPE extends Vector<VECTOR_TYPE>,
DATA_TYPE>
AggregateColumnSource<VECTOR_TYPE,DATA_TYPE> forRangeJoin(@NotNull
 @NotNull ColumnSource<?> aggregatedSource,
 @NotNull
 @NotNull ColumnSource<? extends RowSet> groupRowSetSource,
 @NotNull
 @NotNull ColumnSource<Integer> startPositionInclusiveSource,
 @NotNull
 @NotNull ColumnSource<Integer> endPositionExclusiveSource)

Returns a range aggregated ColumnSource from the provided sources.

Parameters:

aggregatedSource - The input value ColumnSource for the aggregation, in input row key space

groupRowSetSource - ColumnSource of grouped input row sets, in output row key space

startPositionInclusiveSource - ColumnSource of starting positions (inclusive), in output row key space

endPositionExclusiveSource - ColumnSource of ending positions (exclusive), in output row key space