Package com.illumon.iris.db.v2.sources.aggregate

Class LongAggregateColumnSource

java.lang.Object

com.illumon.iris.db.v2.sources.AbstractColumnSource<DB_ARRAY_TYPE>

com.illumon.iris.db.v2.sources.aggregate.LongAggregateColumnSource

All Implemented Interfaces:

AggregateColumnSource<DbLongArray,Long>, ChunkSource<Attributes.Values>, ChunkSource.WithPrev<Attributes.Values>, DefaultChunkSource<Attributes.Values>, DefaultChunkSource.WithPrev<Attributes.Values>, FillContextMaker, GetContextMaker, ColumnSource<DbLongArray>, ColumnSourceGetDefaults.ForObject<DbLongArray>, ElementSource<DbLongArray>, MutableColumnSource<DbLongArray>, MutableColumnSourceGetDefaults.ForObject<DbLongArray>, Releasable, UngroupableColumnSource, TupleExporter<DbLongArray>, TupleSource<DbLongArray>, Serializable

public final class LongAggregateColumnSource
extends AbstractColumnSource<DB_ARRAY_TYPE>

ColumnSource implementation for aggregation result long columns.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.sources.AbstractColumnSource

AbstractColumnSource.DefaultedImmutable<DATA_TYPE>, AbstractColumnSource.DefaultedMutable<DATA_TYPE>, AbstractColumnSource.IsSerializable

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.sources.aggregate.AggregateColumnSource

AggregateColumnSource.AggregateColumnSourceConstructor, AggregateColumnSource.FactoryHelper

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource

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

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.sources.chunk.DefaultChunkSource

DefaultChunkSource.SupportsContiguousGet<ATTR extends Attributes.Any>, DefaultChunkSource.WithPrev<ATTR extends Attributes.Any>

Field Summary

Fields inherited from class com.illumon.iris.db.v2.sources.AbstractColumnSource

componentType, type

Fields inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource

DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAY

Fields inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource.WithPrev

ZERO_LENGTH_CHUNK_SOURCE_WITH_PREV_ARRAY

Fields inherited from interface com.illumon.iris.db.v2.sources.ColumnSource

ZERO_LENGTH_COLUMN_SOURCE_ARRAY

Method Summary

Modifier and Type	Method	Description
void	fillChunk(ChunkSource.FillContext context, WritableChunk<? super Attributes.Values> destination, OrderedKeys orderedKeys)	Populates the given destination chunk with data corresponding to the keys from the given OrderedKeys.
void	fillPrevChunk(ChunkSource.FillContext context, WritableChunk<? super Attributes.Values> destination, OrderedKeys orderedKeys)	Populates the given destination chunk with data corresponding to the keys from the given OrderedKeys.
DbLongArray	get(long index)	Get the value from the source.
DbLongArray	getPrev(long index)	Get the previous value at the index.
final Object	getUngrouped(long groupIndexKey, int offsetInGroup)	Reach into a grouped column source and pull one element out of the array.
final Boolean	getUngroupedBoolean(long groupIndexKey, int offsetInGroup)
final byte	getUngroupedByte(long groupIndexKey, int offsetInGroup)
final char	getUngroupedChar(long groupIndexKey, int offsetInGroup)
final double	getUngroupedDouble(long groupIndexKey, int offsetInGroup)
final float	getUngroupedFloat(long groupIndexKey, int offsetInGroup)
final int	getUngroupedInt(long groupIndexKey, int offsetInGroup)
final long	getUngroupedLong(long groupIndexKey, int offsetInGroup)
final Object	getUngroupedPrev(long groupIndexKey, int offsetInGroup)
final Boolean	getUngroupedPrevBoolean(long groupIndexKey, int offsetInGroup)
final byte	getUngroupedPrevByte(long groupIndexKey, int offsetInGroup)
final char	getUngroupedPrevChar(long groupIndexKey, int offsetInGroup)
final double	getUngroupedPrevDouble(long groupIndexKey, int offsetInGroup)
final float	getUngroupedPrevFloat(long groupIndexKey, int offsetInGroup)
final int	getUngroupedPrevInt(long groupIndexKey, int offsetInGroup)
final long	getUngroupedPrevLong(long groupIndexKey, int offsetInGroup)
final short	getUngroupedPrevShort(long groupIndexKey, int offsetInGroup)
final long	getUngroupedPrevSize(long groupIndexKey)
final short	getUngroupedShort(long groupIndexKey, int offsetInGroup)
final long	getUngroupedSize(long groupIndexKey)
boolean	isImmutable()	Determine if this column source is immutable, meaning that the values at a given index key never change.
final boolean	isUngroupable()	Does this particular instance of the column source support ungrouping?
final ChunkSource.FillContext	makeFillContext(int chunkCapacity, SharedContext sharedContext)	Allocate a new ChunkSource.FillContext for filling chunks from this FillContextMaker, typically a ChunkSource.
final void	startTrackingPrevValues()	ColumnSource implementations that track previous values have the option to not actually start tracking previous values until this method is called.
final UngroupedColumnSource<Long>	ungrouped()

Methods inherited from class com.illumon.iris.db.v2.sources.AbstractColumnSource

allowsReinterpret, canUseGrouping, defaultFillChunk, doReinterpret, getComponentType, getGroupingBuilder, getGroupingProvider, getNativeType, getType, hasGrouping, hasGrouping, isSerializable, match, matchWithGrouping, reinterpret, setGroupingProvider

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource

getChunkType

Methods inherited from interface com.illumon.iris.db.v2.sources.ColumnSource

allowsReinterpret, cast, createPreviousTuple, createTuple, createTupleFromValues, exportElement, exportElement, exportToExternalKey, getColumnSources, getComponentType, getGroupingBuilder, getGroupingProvider, getNativeType, getPrevSource, getType, hasGrouping, hasGrouping, match, reinterpret, releaseCachedResources, setGroupingProvider

Methods inherited from interface com.illumon.iris.db.v2.sources.ColumnSourceGetDefaults.ForObject

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

Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.DefaultChunkSource

getChunk, getChunk, getChunkByFilling, makeGetContext

Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.DefaultChunkSource.WithPrev

getPrevChunk, getPrevChunk, getPrevChunkByFilling

Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.FillContextMaker

makeFillContext

Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.GetContextMaker

makeGetContext

Methods inherited from interface com.illumon.iris.db.v2.sources.MutableColumnSourceGetDefaults.ForObject

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

Methods inherited from interface com.illumon.iris.db.v2.tuples.TupleExporter

exportElementReinterpreted

Methods inherited from interface com.illumon.iris.db.v2.tuples.TupleSource

createTupleFromReinterpretedValues

Method Details

get

public DbLongArray get(long index)

Description copied from interface: ElementSource

Get the value from the source. This may return boxed values for basic types.

Parameters:

index - the location in index space to get the value from.

Returns:

the value at the index, potentially null.

getPrev

public DbLongArray getPrev(long index)

Description copied from interface: ElementSource

Get the previous value at the index. Previous values are used during an LTM update cycle to process changes in data. During normal operation previous values will be identical to current values.

Parameters:

index - the location in index space to get the value from.

Returns:

the previous value at the index, or null.

fillChunk

public void fillChunk(@NotNull
 ChunkSource.FillContext context,
 @NotNull
 WritableChunk<? super Attributes.Values> destination,
 @NotNull
 OrderedKeys orderedKeys)

Description copied from interface: ChunkSource

Populates the given destination chunk with data corresponding to the keys from the given OrderedKeys.

Specified by:

fillChunk in interface ChunkSource<Attributes.Values>

Overrides:

fillChunk in class AbstractColumnSource<DbLongArray>

Parameters:

context - A context containing all mutable/state related data used in retrieving the Chunk.

destination - The chunk to be populated according to orderedKeys. No assumptions shall be made about the size of the chunk shall be made. The chunk will be populated from position [0,orderedKeys.size()).

orderedKeys - An OrderedKeys representing the keys to be fetched

fillPrevChunk

public void fillPrevChunk(@NotNull
 ChunkSource.FillContext context,
 @NotNull
 WritableChunk<? super Attributes.Values> destination,
 @NotNull
 OrderedKeys orderedKeys)

Description copied from interface: ChunkSource.WithPrev

Populates the given destination chunk with data corresponding to the keys from the given OrderedKeys.

Specified by:

fillPrevChunk in interface ChunkSource.WithPrev<Attributes.Values>

Overrides:

fillPrevChunk in class AbstractColumnSource<DbLongArray>

Parameters:

context - A context containing all mutable/state related data used in retrieving the Chunk.

destination - The chunk to be populated according to orderedKeys. No assumptions shall be made about the size of the chunk shall be made. The chunk will be populated from position [0,orderedKeys.size()).

orderedKeys - An OrderedKeys representing the keys to be fetched

ungrouped

public final UngroupedColumnSource<Long> ungrouped()

Specified by:

ungrouped in interface AggregateColumnSource<DB_ARRAY_TYPE extends DbArrayBase,COMPONENT_TYPE>

startTrackingPrevValues

public final void startTrackingPrevValues()

Description copied from interface: ColumnSource

ColumnSource 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:

startTrackingPrevValues in interface ColumnSource<DB_ARRAY_TYPE extends DbArrayBase>

makeFillContext

public final ChunkSource.FillContext makeFillContext(int chunkCapacity,
 SharedContext sharedContext)

Description copied from interface: FillContextMaker

Allocate a new ChunkSource.FillContext for filling chunks from this FillContextMaker, typically a ChunkSource.

Specified by:

makeFillContext in interface DefaultChunkSource<DB_ARRAY_TYPE extends DbArrayBase>

Specified by:

makeFillContext in interface FillContextMaker

Parameters:

chunkCapacity - The maximum size of any WritableChunk that will be filled with this context

sharedContext - Shared store of intermediate results.

Returns:

A context for use with fill operations

isUngroupable

public final boolean isUngroupable()

Description copied from interface: UngroupableColumnSource

Does this particular instance of the column source support ungrouping?

Specified by:

isUngroupable in interface UngroupableColumnSource

Returns:

true if you can call the getUngrouped family of methods and get a valid answer.

getUngroupedSize

public final long getUngroupedSize(long groupIndexKey)

Specified by:

getUngroupedSize in interface UngroupableColumnSource

Parameters:

groupIndexKey - the index within this column to interrogate

Returns:

the size of the DbArray at columnIndex.

getUngroupedPrevSize

public final long getUngroupedPrevSize(long groupIndexKey)

Specified by:

getUngroupedPrevSize in interface UngroupableColumnSource

getUngrouped

public final Object getUngrouped(long groupIndexKey,
 int offsetInGroup)

Description copied from interface: UngroupableColumnSource

Reach into a grouped column source and pull one element out of the array.

Specified by:

getUngrouped in interface UngroupableColumnSource

Parameters:

groupIndexKey - the index within the column of the cell to get

offsetInGroup - the index within the array at the specified cell

Returns:

Equivalent to ((DbArray)columnSource.get(columnIndex)).get(arrayIndex)

getUngroupedPrev

public final Object getUngroupedPrev(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrev in interface UngroupableColumnSource

getUngroupedBoolean

public final Boolean getUngroupedBoolean(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedBoolean in interface UngroupableColumnSource

getUngroupedPrevBoolean

public final Boolean getUngroupedPrevBoolean(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevBoolean in interface UngroupableColumnSource

getUngroupedDouble

public final double getUngroupedDouble(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedDouble in interface UngroupableColumnSource

getUngroupedPrevDouble

public final double getUngroupedPrevDouble(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevDouble in interface UngroupableColumnSource

getUngroupedFloat

public final float getUngroupedFloat(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedFloat in interface UngroupableColumnSource

getUngroupedPrevFloat

public final float getUngroupedPrevFloat(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevFloat in interface UngroupableColumnSource

getUngroupedByte

public final byte getUngroupedByte(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedByte in interface UngroupableColumnSource

getUngroupedPrevByte

public final byte getUngroupedPrevByte(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevByte in interface UngroupableColumnSource

getUngroupedChar

public final char getUngroupedChar(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedChar in interface UngroupableColumnSource

getUngroupedPrevChar

public final char getUngroupedPrevChar(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevChar in interface UngroupableColumnSource

getUngroupedShort

public final short getUngroupedShort(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedShort in interface UngroupableColumnSource

getUngroupedPrevShort

public final short getUngroupedPrevShort(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevShort in interface UngroupableColumnSource

getUngroupedInt

public final int getUngroupedInt(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedInt in interface UngroupableColumnSource

getUngroupedPrevInt

public final int getUngroupedPrevInt(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevInt in interface UngroupableColumnSource

getUngroupedLong

public final long getUngroupedLong(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedLong in interface UngroupableColumnSource

getUngroupedPrevLong

public final long getUngroupedPrevLong(long groupIndexKey,
 int offsetInGroup)

Specified by:

getUngroupedPrevLong in interface UngroupableColumnSource

isImmutable

public boolean isImmutable()

Description copied from interface: ColumnSource

Determine if this column source is immutable, meaning that the values at a given index key never change.

Specified by:

isImmutable in interface ColumnSource<DB_ARRAY_TYPE extends DbArrayBase>

Specified by:

isImmutable in interface MutableColumnSource<DB_ARRAY_TYPE extends DbArrayBase>

Returns:

true if the values at a given index of the column source never change, false otherwise