Package com.illumon.iris.db.v2.sources
Class UnionColumnSource<T>
java.lang.Object
com.illumon.iris.db.v2.sources.AbstractColumnSource<T>
com.illumon.iris.db.v2.sources.UnionColumnSource<T>
- All Implemented Interfaces:
ChunkSource<Attributes.Values>,ChunkSource.WithPrev<Attributes.Values>,DefaultChunkSource<Attributes.Values>,DefaultChunkSource.WithPrev<Attributes.Values>,FillContextMaker,GetContextMaker,ColumnSource<T>,ElementSource<T>,Releasable,TupleExporter<T>,TupleSource<T>,Serializable
ColumnSource implementation for
TableTools.merge(java.util.List<com.illumon.iris.db.tables.Table>) results.- See Also:
-
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.IsSerializableNested classes/interfaces inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource
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, typeFields inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource
DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAYFields inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource.WithPrev
ZERO_LENGTH_CHUNK_SOURCE_WITH_PREV_ARRAYFields inherited from interface com.illumon.iris.db.v2.sources.ColumnSource
ZERO_LENGTH_COLUMN_SOURCE_ARRAY -
Method Summary
Modifier and TypeMethodDescription<ALTERNATE_DATA_TYPE>
booleanallowsReinterpret(Class<ALTERNATE_DATA_TYPE> alternateDataType) Test if a reinterpret call will succeed.protected <ALTERNATE_DATA_TYPE>
ColumnSource<ALTERNATE_DATA_TYPE>doReinterpret(Class<ALTERNATE_DATA_TYPE> alternateDataType) Supply allowed reinterpret results.voidfillChunk(ChunkSource.FillContext _context, WritableChunk<? super Attributes.Values> destination, OrderedKeys orderedKeys) Populates the given destination chunk with data corresponding to the keys from the givenOrderedKeys.voidfillPrevChunk(ChunkSource.FillContext _context, WritableChunk<? super Attributes.Values> destination, OrderedKeys orderedKeys) Populates the given destination chunk with data corresponding to the keys from the givenOrderedKeys.get(long index) Get the value from the source.getBoolean(long index) Get the value at the index as a Boolean.bytegetByte(long index) Get the value at the index as a byte.chargetChar(long index) Get the value at the index as a char.doublegetDouble(long index) Get the value at the index as a double.floatgetFloat(long index) Get the value at the index as a float.intgetInt(long index) Get the value at the index as an int.longgetLong(long index) Get the value at the index as a long.getPrev(long index) Get the previous value at the index.getPrevBoolean(long index) Get the previous value at the index as a Boolean.bytegetPrevByte(long index) Get the previous value at the index as a byte.chargetPrevChar(long index) Get the previous value at the index as a char.doublegetPrevDouble(long index) Get the previous value at the index as a double.floatgetPrevFloat(long index) Get the previous value at the index as a float.intgetPrevInt(long index) Get the previous value at the index as an int.longgetPrevLong(long index) Get the previous value at the index as a long.shortgetPrevShort(long index) Get the previous value at the index as a short.shortgetShort(long index) Get the value at the index as a short.getSubSource(int i) Return the Union source manager that was used to create this table.booleanDetermine if this column source is immutable, meaning that the values at a given index key never change.makeFillContext(int chunkCapacity, SharedContext sharedContext) Allocate a newChunkSource.FillContextfor filling chunks from thisFillContextMaker, typically aChunkSource.Methods inherited from class com.illumon.iris.db.v2.sources.AbstractColumnSource
canUseGrouping, defaultFillChunk, getComponentType, getGroupingBuilder, getGroupingProvider, getNativeType, getType, hasGrouping, hasGrouping, isSerializable, match, matchWithGrouping, reinterpret, setGroupingProviderMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource
getChunkTypeMethods inherited from interface com.illumon.iris.db.v2.sources.ColumnSource
cast, createPreviousTuple, createTuple, createTupleFromValues, exportElement, exportElement, exportToExternalKey, getColumnSources, getPrevSource, releaseCachedResources, startTrackingPrevValuesMethods inherited from interface com.illumon.iris.db.v2.sources.chunk.DefaultChunkSource
getChunk, getChunk, getChunkByFilling, makeGetContextMethods inherited from interface com.illumon.iris.db.v2.sources.chunk.DefaultChunkSource.WithPrev
getPrevChunk, getPrevChunk, getPrevChunkByFillingMethods inherited from interface com.illumon.iris.db.v2.sources.chunk.FillContextMaker
makeFillContextMethods inherited from interface com.illumon.iris.db.v2.sources.chunk.GetContextMaker
makeGetContextMethods inherited from interface com.illumon.iris.db.v2.tuples.TupleExporter
exportElementReinterpretedMethods inherited from interface com.illumon.iris.db.v2.tuples.TupleSource
createTupleFromReinterpretedValues
-
Method Details
-
getBoolean
Description copied from interface:ElementSourceGet the value at the index as a Boolean.- Parameters:
index- the location in index space to get the value from.- Returns:
- the boolean at the index, potentially null.
-
getByte
public byte getByte(long index) Description copied from interface:ElementSourceGet the value at the index as a byte.- Parameters:
index- the location in index space to get the value from.- Returns:
- the boolean at the index, null values are represented by
QueryConstants.NULL_BYTE
-
getChar
public char getChar(long index) Description copied from interface:ElementSourceGet the value at the index as a char.- Parameters:
index- the location in index space to get the value from.- Returns:
- the char at the index, null values are represented by
QueryConstants.NULL_CHAR
-
getDouble
public double getDouble(long index) Description copied from interface:ElementSourceGet the value at the index as a double.- Parameters:
index- the location in index space to get the value from.- Returns:
- the double at the index, null values are represented by
QueryConstants.NULL_DOUBLE
-
getFloat
public float getFloat(long index) Description copied from interface:ElementSourceGet the value at the index as a float.- Parameters:
index- the location in index space to get the value from.- Returns:
- the float at the index, null values are represented by
QueryConstants.NULL_FLOAT
-
getInt
public int getInt(long index) Description copied from interface:ElementSourceGet the value at the index as an int.- Parameters:
index- the location in index space to get the value from.- Returns:
- the int at the index, null values are represented by
QueryConstants.NULL_INT
-
getLong
public long getLong(long index) Description copied from interface:ElementSourceGet the value at the index as a long.- Parameters:
index- the location in index space to get the value from.- Returns:
- the long at the index, null values are represented by
QueryConstants.NULL_LONG
-
getShort
public short getShort(long index) Description copied from interface:ElementSourceGet the value at the index as a short.- Parameters:
index- the location in index space to get the value from.- Returns:
- the short at the index, null values are represented by
QueryConstants.NULL_SHORT
-
get
Description copied from interface:ElementSourceGet 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
Description copied from interface:ElementSourceGet the previous value at the index. Previous values are used during anLTMupdatecycle to process changes in data. Duringnormaloperation previous values will be identical tocurrentvalues.- Parameters:
index- the location in index space to get the value from.- Returns:
- the previous value at the index, or null.
-
getPrevBoolean
Description copied from interface:ElementSourceGet the previous value at the index as a Boolean. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous boolean at the index, or null.
-
getPrevByte
public byte getPrevByte(long index) Description copied from interface:ElementSourceGet the previous value at the index as a byte. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous boolean at the index, null values are represented by
QueryConstants.NULL_BYTE
-
getPrevChar
public char getPrevChar(long index) Description copied from interface:ElementSourceGet the previous value at the index as a char. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous char at the index, null values are represented by
QueryConstants.NULL_CHAR
-
getPrevDouble
public double getPrevDouble(long index) Description copied from interface:ElementSourceGet the previous value at the index as a double. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous double at the index, null values are represented by
QueryConstants.NULL_DOUBLE
-
getPrevFloat
public float getPrevFloat(long index) Description copied from interface:ElementSourceGet the previous value at the index as a float. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous float at the index, null values are represented by
QueryConstants.NULL_FLOAT
-
getPrevInt
public int getPrevInt(long index) Description copied from interface:ElementSourceGet the previous value at the index as an int. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous int at the index, null values are represented by
QueryConstants.NULL_INT
-
getPrevLong
public long getPrevLong(long index) Description copied from interface:ElementSourceGet the previous value at the index as a long. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous long at the index, null values are represented by
QueryConstants.NULL_LONG
-
getPrevShort
public short getPrevShort(long index) Description copied from interface:ElementSourceGet the previous value at the index as a short. SeeElementSource.getPrev(long)for more details.- Parameters:
index- the location in index space to get the previous value from.- Returns:
- the previous short at the index, null values are represented by
QueryConstants.NULL_SHORT
-
isImmutable
public boolean isImmutable()Description copied from interface:ColumnSourceDetermine if this column source is immutable, meaning that the values at a given index key never change.- Returns:
- true if the values at a given index of the column source never change, false otherwise
-
fillChunk
public void fillChunk(@NotNull ChunkSource.FillContext _context, @NotNull WritableChunk<? super Attributes.Values> destination, @NotNull OrderedKeys orderedKeys) Description copied from interface:ChunkSourcePopulates the given destination chunk with data corresponding to the keys from the givenOrderedKeys.- Specified by:
fillChunkin interfaceChunkSource<T>- Overrides:
fillChunkin classAbstractColumnSource<T>- Parameters:
_context- A context containing all mutable/state related data used in retrieving the Chunk.destination- The chunk to be populated according toorderedKeys. 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- AnOrderedKeysrepresenting 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.WithPrevPopulates the given destination chunk with data corresponding to the keys from the givenOrderedKeys.- Specified by:
fillPrevChunkin interfaceChunkSource.WithPrev<T>- Overrides:
fillPrevChunkin classAbstractColumnSource<T>- Parameters:
_context- A context containing all mutable/state related data used in retrieving the Chunk.destination- The chunk to be populated according toorderedKeys. 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- AnOrderedKeysrepresenting the keys to be fetched
-
getUnionSourceManager
Return the Union source manager that was used to create this table. -
getSubSource
-
allowsReinterpret
public <ALTERNATE_DATA_TYPE> boolean allowsReinterpret(@NotNull Class<ALTERNATE_DATA_TYPE> alternateDataType) Description copied from interface:ColumnSourceTest if a reinterpret call will succeed.- Specified by:
allowsReinterpretin interfaceColumnSource<T>- Overrides:
allowsReinterpretin classAbstractColumnSource<T>- Type Parameters:
ALTERNATE_DATA_TYPE- the dataType to inquire about- Parameters:
alternateDataType- The alternative type to consider- Returns:
- If a reinterpret on this column source with the supplied alternateDataType will succeed.
-
doReinterpret
protected <ALTERNATE_DATA_TYPE> ColumnSource<ALTERNATE_DATA_TYPE> doReinterpret(@NotNull Class<ALTERNATE_DATA_TYPE> alternateDataType) Description copied from class:AbstractColumnSourceSupply allowed reinterpret results. The default implementation handles the most common case to avoid code duplication.- Overrides:
doReinterpretin classAbstractColumnSource<T>- Type Parameters:
ALTERNATE_DATA_TYPE- the dataType to reinterpret to- Parameters:
alternateDataType- The alternate data type- Returns:
- The resulting
ColumnSource
-