Class BaseAggregateSlicedColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>,COMPONENT_TYPE>
java.lang.Object
io.deephaven.engine.table.impl.AbstractColumnSource<VECTOR_TYPE>
io.deephaven.engine.table.impl.sources.aggregate.BaseAggregateSlicedColumnSource<VECTOR_TYPE,COMPONENT_TYPE>
- All Implemented Interfaces:
ChunkSource<Values>,ChunkSource.WithPrev<Values>,ColumnSource<VECTOR_TYPE>,ElementSource<VECTOR_TYPE>,FillContextMaker,GetContextMaker,ColumnSourceGetDefaults.ForObject<VECTOR_TYPE>,DefaultChunkSource<Values>,DefaultChunkSource.WithPrev<Values>,MutableColumnSource<VECTOR_TYPE>,MutableColumnSourceGetDefaults.ForObject<VECTOR_TYPE>,PushdownFilterMatcher,AggregateColumnSource<VECTOR_TYPE,,COMPONENT_TYPE> UngroupableColumnSource,Releasable,TupleExporter<VECTOR_TYPE>,TupleSource<VECTOR_TYPE>
- Direct Known Subclasses:
SlicedByteAggregateColumnSource,SlicedCharAggregateColumnSource,SlicedDoubleAggregateColumnSource,SlicedFloatAggregateColumnSource,SlicedIntAggregateColumnSource,SlicedLongAggregateColumnSource,SlicedObjectAggregateColumnSource,SlicedShortAggregateColumnSource
public abstract class BaseAggregateSlicedColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>,COMPONENT_TYPE>
extends AbstractColumnSource<VECTOR_TYPE>
implements AggregateColumnSource<VECTOR_TYPE,COMPONENT_TYPE>
Base
ColumnSource implementation for sliced rowset aggregation result columns.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static final classNested classes/interfaces inherited from class io.deephaven.engine.table.impl.AbstractColumnSource
AbstractColumnSource.DefaultedImmutable<DATA_TYPE>, AbstractColumnSource.DefaultedMutable<DATA_TYPE>Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.sources.aggregate.AggregateColumnSource
AggregateColumnSource.FactoryHelperNested 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.impl.DefaultChunkSource
DefaultChunkSource.SupportsContiguousGet<ATTR extends Any>, DefaultChunkSource.WithPrev<ATTR extends Any>Nested classes/interfaces inherited from interface io.deephaven.engine.table.TupleExporter
TupleExporter.ExportElementFunction<TUPLE_TYPE> -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final ColumnSource<COMPONENT_TYPE>protected final ColumnSource<COMPONENT_TYPE>protected final longprotected final @Nullable ColumnSource<Long>protected final ColumnSource<? extends RowSet>protected final longprotected final @Nullable ColumnSource<Long>Fields inherited from class io.deephaven.engine.table.impl.AbstractColumnSource
componentType, type, updateGraph, USE_RANGES_AVERAGE_RUN_LENGTHFields inherited from interface io.deephaven.engine.table.ChunkSource
DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAYFields inherited from interface io.deephaven.engine.table.ChunkSource.WithPrev
ZERO_LENGTH_CHUNK_SOURCE_WITH_PREV_ARRAYFields inherited from interface io.deephaven.engine.table.ColumnSource
ZERO_LENGTH_COLUMN_SOURCE_ARRAY -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedBaseAggregateSlicedColumnSource(@NotNull Class<VECTOR_TYPE> vectorType, @NotNull ColumnSource<COMPONENT_TYPE> aggregatedSource, @NotNull ColumnSource<? extends RowSet> groupRowSetSource, long startOffset, long endOffset) protectedBaseAggregateSlicedColumnSource(@NotNull Class<VECTOR_TYPE> vectorType, @NotNull ColumnSource<COMPONENT_TYPE> aggregatedSource, @NotNull ColumnSource<? extends RowSet> groupRowSetSource, @NotNull ColumnSource<Long> startSource, @NotNull ColumnSource<Long> endSource) -
Method Summary
Modifier and TypeMethodDescriptionprotected RowSetgetPrevGroupRowSet(long groupIndexKey) final ObjectgetUngrouped(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one Object element out of the vector.final BooleangetUngroupedBoolean(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one Boolean element out of the vector.final bytegetUngroupedByte(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one byte element out of the vector.final chargetUngroupedChar(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one char element out of the vector.final doublegetUngroupedDouble(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one double element out of the vector.final floatgetUngroupedFloat(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one float element out of the vector.final intgetUngroupedInt(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one int element out of the vector.final longgetUngroupedLong(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one long element out of the vector.final ObjectgetUngroupedPrev(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one Object element out of the vector as of end of the previous update cycle.final BooleangetUngroupedPrevBoolean(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one Boolean element out of the vector as of end of the previous update cycle.final bytegetUngroupedPrevByte(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one byte element out of the vector as of end of the previous update cycle.final chargetUngroupedPrevChar(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one char element out of the vector as of end of the previous update cycle.final doublegetUngroupedPrevDouble(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one double element out of the vector as of end of the previous update cycle.final floatgetUngroupedPrevFloat(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one float element out of the vector as of end of the previous update cycle.final intgetUngroupedPrevInt(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one int element out of the vector as of end of the previous update cycle.final longgetUngroupedPrevLong(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one long element out of the vector as of end of the previous update cycle.final shortgetUngroupedPrevShort(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one short element out of the vector as of end of the previous update cycle.final longgetUngroupedPrevSize(long groupRowKey) final shortgetUngroupedShort(long groupRowKey, int offsetInGroup) Reach into a grouped column source and pull one short element out of the vector.longgetUngroupedSize(long groupRowKey) booleanDetermine if this column source is immutable, meaning that the values at a given row key never change.booleanMost column sources will return the same value for a given row without respect to the order that the rows are read.final booleanDoes this particular ColumnSource support ungrouping?final ChunkSource.FillContextmakeFillContext(int chunkCapacity, SharedContext sharedContext) Allocate a newChunkSource.FillContextfor filling chunks from thisFillContextMaker, typically aChunkSource.final voidColumnSource implementations that track previous values have the option to not actually start tracking previous values until this method is called.Methods inherited from class io.deephaven.engine.table.impl.AbstractColumnSource
allowsReinterpret, defaultFillChunk, defaultFillPrevChunk, doReinterpret, estimatePushdownFilterCost, fillChunk, fillPrevChunk, getComponentType, getPrevSource, getType, makePushdownFilterContext, match, pushdownFilter, pushdownManager, reinterpretMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface io.deephaven.engine.table.ChunkSource
fillChunkMethods inherited from interface io.deephaven.engine.table.ChunkSource.WithPrev
fillPrevChunkMethods inherited from interface io.deephaven.engine.table.ColumnSource
allowsReinterpret, cast, cast, cast, cast, createPreviousTuple, createTuple, createTupleFromValues, exportAllTo, exportElement, exportElement, getChunkType, getComponentType, getPrevSource, getType, match, reinterpret, releaseCachedResources, tupleLengthMethods inherited from interface io.deephaven.engine.table.impl.ColumnSourceGetDefaults.ForObject
getBoolean, getByte, getChar, getDouble, getFloat, getInt, getLong, getShortMethods inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource
getChunk, getChunk, getChunkByFilling, makeGetContextMethods inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource.WithPrev
getPrevChunk, getPrevChunk, getPrevChunkByFillingMethods inherited from interface io.deephaven.engine.table.ElementSource
get, getPrevMethods inherited from interface io.deephaven.engine.table.FillContextMaker
makeFillContextMethods inherited from interface io.deephaven.engine.table.GetContextMaker
makeGetContextMethods inherited from interface io.deephaven.engine.table.impl.MutableColumnSourceGetDefaults.ForObject
getPrevBoolean, getPrevByte, getPrevChar, getPrevDouble, getPrevFloat, getPrevInt, getPrevLong, getPrevShortMethods inherited from interface io.deephaven.engine.table.TupleExporter
exportAllReinterpretedTo, exportAllReinterpretedTo, exportAllTo, exportElementReinterpretedMethods inherited from interface io.deephaven.engine.table.TupleSource
createTupleFromReinterpretedValuesMethods inherited from interface io.deephaven.engine.table.impl.sources.UngroupableColumnSource
getUngroupedPrevSize, getUngroupedSize
-
Field Details
-
aggregatedSource
-
aggregatedSourcePrev
-
groupRowSetSource
-
startSource
-
endSource
-
startOffset
protected final long startOffset -
endOffset
protected final long endOffset
-
-
Constructor Details
-
BaseAggregateSlicedColumnSource
protected BaseAggregateSlicedColumnSource(@NotNull @NotNull Class<VECTOR_TYPE> vectorType, @NotNull @NotNull ColumnSource<COMPONENT_TYPE> aggregatedSource, @NotNull @NotNull ColumnSource<? extends RowSet> groupRowSetSource, @NotNull @NotNull ColumnSource<Long> startSource, @NotNull @NotNull ColumnSource<Long> endSource) -
BaseAggregateSlicedColumnSource
protected BaseAggregateSlicedColumnSource(@NotNull @NotNull Class<VECTOR_TYPE> vectorType, @NotNull @NotNull ColumnSource<COMPONENT_TYPE> aggregatedSource, @NotNull @NotNull ColumnSource<? extends RowSet> groupRowSetSource, long startOffset, long endOffset)
-
-
Method Details
-
ungrouped
- Specified by:
ungroupedin interfaceAggregateColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>,COMPONENT_TYPE>
-
startTrackingPrevValues
public final void startTrackingPrevValues()Description copied from interface:ColumnSourceColumnSource implementations that track previous values have the option to not actually start tracking previous values until this method is called. This is an option, not an obligation: some simple ColumnSource implementations (like TSingleValueSource for various T) always track previous values; other implementations (like PrevColumnSource) never do; some (like TArrayColumnSource) only start tracking once this method is called. An immutable column source can not have distinct prev values; therefore it is implemented as a no-op.- Specified by:
startTrackingPrevValuesin interfaceColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>>
-
isUngroupable
public final boolean isUngroupable()Description copied from interface:UngroupableColumnSourceDoes this particular ColumnSource support ungrouping?- Specified by:
isUngroupablein interfaceUngroupableColumnSource- Returns:
trueif you can call the getUngrouped family of methods and get a valid answer
-
getUngroupedSize
public long getUngroupedSize(long groupRowKey) - Specified by:
getUngroupedSizein interfaceUngroupableColumnSource
-
getUngroupedPrevSize
public final long getUngroupedPrevSize(long groupRowKey) - Specified by:
getUngroupedPrevSizein interfaceUngroupableColumnSource
-
getPrevGroupRowSet
-
getUngrouped
Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one Object element out of the vector.- Specified by:
getUngroupedin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ObjectVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrev
Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one Object element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ObjectVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedBoolean
Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one Boolean element out of the vector.- Specified by:
getUngroupedBooleanin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ObjectVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevBoolean
Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one Boolean element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevBooleanin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ObjectVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedDouble
public final double getUngroupedDouble(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one double element out of the vector.- Specified by:
getUngroupedDoublein interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((DoubleVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevDouble
public final double getUngroupedPrevDouble(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one double element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevDoublein interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((DoubleVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedFloat
public final float getUngroupedFloat(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one float element out of the vector.- Specified by:
getUngroupedFloatin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((FloatVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevFloat
public final float getUngroupedPrevFloat(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one float element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevFloatin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((FloatVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedByte
public final byte getUngroupedByte(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one byte element out of the vector.- Specified by:
getUngroupedBytein interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ByteVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevByte
public final byte getUngroupedPrevByte(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one byte element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevBytein interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ByteVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedChar
public final char getUngroupedChar(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one char element out of the vector.- Specified by:
getUngroupedCharin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((CharVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevChar
public final char getUngroupedPrevChar(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one char element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevCharin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((CharVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedShort
public final short getUngroupedShort(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one short element out of the vector.- Specified by:
getUngroupedShortin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ShortVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevShort
public final short getUngroupedPrevShort(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one short element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevShortin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((ShortVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedInt
public final int getUngroupedInt(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one int element out of the vector.- Specified by:
getUngroupedIntin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((IntVector)columnSource.get(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevInt
public final int getUngroupedPrevInt(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one int element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevIntin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((IntVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
getUngroupedLong
public final long getUngroupedLong(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one long element out of the vector.- Specified by:
getUngroupedLongin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((LongVector)columnSource.getLong(groupRowKey)).get(offsetInGroup)
-
getUngroupedPrevLong
public final long getUngroupedPrevLong(long groupRowKey, int offsetInGroup) Description copied from interface:UngroupableColumnSourceReach into a grouped column source and pull one long element out of the vector as of end of the previous update cycle.- Specified by:
getUngroupedPrevLongin interfaceUngroupableColumnSource- Parameters:
groupRowKey- The vector's row key in the grouped column sourceoffsetInGroup- Positional offset within the vector atgroupRowKey- Returns:
- Equivalent to ((LongVector)columnSource.getPrev(groupRowKey)).get(offsetInGroup)
-
isStateless
public boolean isStateless()Description copied from interface:ColumnSourceMost column sources will return the same value for a given row without respect to the order that the rows are read. Those columns sources are considered "stateless" and should return true. Some column sources, however may be dependent on evaluation order. For example, a formula that updates a Map must be evaluated from the first row to the last row. A column source that has the potential to depend on the order of evaluation must return false.- Specified by:
isStatelessin interfaceColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>>- Returns:
- true if this is a stateless column source
-
isImmutable
public boolean isImmutable()Description copied from interface:ColumnSourceDetermine if this column source is immutable, meaning that the values at a given row key never change.- Specified by:
isImmutablein interfaceColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>>- Specified by:
isImmutablein interfaceMutableColumnSource<VECTOR_TYPE extends Vector<VECTOR_TYPE>>- Returns:
- true if the values at a given row key of the column source never change, false otherwise
-