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
public class UnionColumnSource<T> extends AbstractColumnSource<T>
ColumnSource implementation for
TableTools.merge(java.util.List<com.illumon.iris.db.tables.Table>)
results.- 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.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 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 <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.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 givenOrderedKeys
.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 givenOrderedKeys
.T
get(long index)
Get the value from the source.Boolean
getBoolean(long index)
Get the value at the index as a Boolean.byte
getByte(long index)
Get the value at the index as a byte.char
getChar(long index)
Get the value at the index as a char.double
getDouble(long index)
Get the value at the index as a double.float
getFloat(long index)
Get the value at the index as a float.int
getInt(long index)
Get the value at the index as an int.long
getLong(long index)
Get the value at the index as a long.T
getPrev(long index)
Get the previous value at the index.Boolean
getPrevBoolean(long index)
Get the previous value at the index as a Boolean.byte
getPrevByte(long index)
Get the previous value at the index as a byte.char
getPrevChar(long index)
Get the previous value at the index as a char.double
getPrevDouble(long index)
Get the previous value at the index as a double.float
getPrevFloat(long index)
Get the previous value at the index as a float.int
getPrevInt(long index)
Get the previous value at the index as an int.long
getPrevLong(long index)
Get the previous value at the index as a long.short
getPrevShort(long index)
Get the previous value at the index as a short.short
getShort(long index)
Get the value at the index as a short.ColumnSource
getSubSource(int i)
UnionSourceManager
getUnionSourceManager()
Return the Union source manager that was used to create this table.boolean
isImmutable()
Determine if this column source is immutable, meaning that the values at a given index key never change.ChunkSource.FillContext
makeFillContext(int chunkCapacity, SharedContext sharedContext)
Allocate a newChunkSource.FillContext
for filling chunks from thisFillContextMaker
, typically aChunkSource
.Methods inherited from class com.illumon.iris.db.v2.sources.AbstractColumnSource
defaultFillChunk, getComponentType, getGroupingBuilder, getGroupingProvider, getNativeType, getType, hasGrouping, isSerializable, match, 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.ColumnSource
cast, createPreviousTuple, createTuple, createTupleFromValues, exportElement, exportElement, exportToExternalKey, getColumnSources, getPrevSource, releaseCachedResources, startTrackingPrevValues
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.tuples.TupleExporter
exportElementReinterpreted
Methods inherited from interface com.illumon.iris.db.v2.tuples.TupleSource
createTupleFromReinterpretedValues
-
Method Details
-
getBoolean
Description copied from interface:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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: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
Description copied from interface:ElementSource
Get the previous value at the index. Previous values are used during anLTM
update
cycle to process changes in data. Duringnormal
operation previous values will be identical tocurrent
values.- 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ElementSource
Get 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:ColumnSource
Determine 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
-
makeFillContext
Description copied from interface:FillContextMaker
Allocate a newChunkSource.FillContext
for filling chunks from thisFillContextMaker
, typically aChunkSource
.- Parameters:
chunkCapacity
- The maximum size of anyWritableChunk
that will be filled with this contextsharedContext
- Shared store of intermediate results.- Returns:
- A context for use with fill operations
-
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 givenOrderedKeys
.- Specified by:
fillChunk
in interfaceChunkSource<T>
- Overrides:
fillChunk
in 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
- AnOrderedKeys
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 givenOrderedKeys
.- Specified by:
fillPrevChunk
in interfaceChunkSource.WithPrev<T>
- Overrides:
fillPrevChunk
in 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
- AnOrderedKeys
representing 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:ColumnSource
Test if a reinterpret call will succeed.- Specified by:
allowsReinterpret
in interfaceColumnSource<T>
- Overrides:
allowsReinterpret
in 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:AbstractColumnSource
Supply allowed reinterpret results. The default implementation handles the most common case to avoid code duplication.- Overrides:
doReinterpret
in classAbstractColumnSource<T>
- Type Parameters:
ALTERNATE_DATA_TYPE
- the dataType to reinterpret to- Parameters:
alternateDataType
- The alternate data type- Returns:
- The resulting
ColumnSource
-