Class RegionedColumnSourcePartitioning
java.lang.Object
com.illumon.iris.db.v2.sources.AbstractColumnSource<DATA_TYPE>
com.illumon.iris.db.v2.sources.regioned.RegionedColumnSourceBase<DATA_TYPE,ATTR,REGION_TYPE>
com.illumon.iris.db.v2.sources.regioned.RegionedColumnSourcePartitioning
- All Implemented Interfaces:
LongSizedDataStructure
,ChunkSource<Attributes.Values>
,ChunkSource.WithPrev<Attributes.Values>
,DefaultChunkSource<Attributes.Values>
,DefaultChunkSource.SupportsContiguousGet<Attributes.Values>
,DefaultChunkSource.WithPrev<Attributes.Values>
,FillContextMaker
,GetContextMaker
,PageStore<Attributes.Values,
,Attributes.Values, ColumnRegionObject<String, Attributes.Values>> PagingChunkSource<Attributes.Values>
,ColumnSource<String>
,ColumnSourceGetDefaults.ForObject<String>
,ElementSource<String>
,ImmutableColumnSource<String>
,MakeRegion<Attributes.Values,
,ColumnRegionObject<String, Attributes.Values>> PartitioningRegionedSource
,RegionedColumnSource<String>
,RegionedPageStore<Attributes.Values,
,Attributes.Values, ColumnRegionObject<String, Attributes.Values>> Releasable
,SizedColumnSource<String>
,TupleExporter<String>
,TupleSource<String>
,Serializable
public class RegionedColumnSourcePartitioning
extends RegionedColumnSourceBase<DATA_TYPE,ATTR,REGION_TYPE>
implements ColumnSourceGetDefaults.ForObject<String>, PartitioningRegionedSource
- 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.IsSerializable
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>
Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.sources.regioned.RegionedPageStore
RegionedPageStore.Helper, RegionedPageStore.Static<ATTR extends Attributes.Values,
INNER_ATTR extends ATTR, REGION_TYPE extends ColumnRegion<INNER_ATTR>> -
Field Summary
Fields inherited from class com.illumon.iris.db.v2.sources.regioned.RegionedColumnSourceBase
USE_PARALLEL, USE_PUSHDOWN
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
Fields inherited from interface com.illumon.iris.db.v2.sources.regioned.RegionedColumnSource
ELEMENT_INDEX_TO_SUB_REGION_ELEMENT_INDEX_MASK, MAXIMUM_REGION_COUNT, REGION_CAPACITY_IN_ELEMENTS, REGION_INDEX_ADDRESS_BITS, SUB_REGION_ELEMENT_INDEX_ADDRESS_BITS
Fields inherited from interface com.illumon.iris.db.v2.sources.regioned.RegionedPageStore
REGION_MASK, REGION_MASK_NUM_BITS
-
Method Summary
Modifier and TypeMethodDescriptionint
addRegion
(com.illumon.dataobjects.ColumnDefinition<?> columnDefinition, ColumnLocation columnLocation, SourceTableColumnInstructions instructions) Add a region to this regioned column source.get
(long elementIndex) Get the value from the source.Get the factory for converting locations to partition valuesgetRegion
(int regionIndex) Map from a region index to its corresponding region.final int
Get the number of regions.makeRegion
(com.illumon.dataobjects.ColumnDefinition<?> columnDefinition, ColumnLocation columnLocation, SourceTableColumnInstructions instructions, int regionIndex) Get a new or re-usable column region appropriate for this source.void
Release any resources held for caching purposes.Methods inherited from class com.illumon.iris.db.v2.sources.regioned.RegionedColumnSourceBase
disableGrouping, doMatchWithGrouping, fillChunk, fillPrevChunk, match
Methods inherited from class com.illumon.iris.db.v2.sources.AbstractColumnSource
allowsReinterpret, canUseGrouping, defaultFillChunk, doReinterpret, getComponentType, getGroupingBuilder, getGroupingProvider, getNativeType, getType, hasGrouping, isSerializable, 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.chunk.ChunkSource.WithPrev
fillPrevChunk
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, match, reinterpret, releaseCachedResources, setGroupingProvider, startTrackingPrevValues
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
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.ImmutableColumnSource
getPrev, getPrevBoolean, getPrevByte, getPrevChar, getPrevDouble, getPrevFloat, getPrevInt, getPrevLong, getPrevShort, isImmutable
Methods inherited from interface com.illumon.iris.db.util.LongSizedDataStructure
intSize, intSize
Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.page.PageStore
doFillChunkAppend, fillChunkAppend, getChunk, getChunk
Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.page.PagingChunkSource
maxRow
Methods inherited from interface com.illumon.iris.db.v2.sources.regioned.RegionedColumnSource
addRegion, disableGrouping
Methods inherited from interface com.illumon.iris.db.v2.sources.regioned.RegionedPageStore
getPageContaining, lookupRegion, makeFillContext, mask, size
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
Description copied from interface:ElementSource
Get the value from the source. This may return boxed values for basic types.- Specified by:
get
in interfaceElementSource<String>
- Parameters:
elementIndex
- the location in index space to get the value from.- Returns:
- the value at the index, potentially null.
-
makeRegion
public ColumnRegionObject<String,Attributes.Values> makeRegion(@NotNull com.illumon.dataobjects.ColumnDefinition<?> columnDefinition, @NotNull ColumnLocation columnLocation, @NotNull SourceTableColumnInstructions instructions, int regionIndex) Description copied from interface:MakeRegion
Get a new or re-usable column region appropriate for this source.- Specified by:
makeRegion
in interfaceMakeRegion<Attributes.Values,
ColumnRegionObject<String, Attributes.Values>> - Parameters:
columnDefinition
- TheColumnDefinition
columnLocation
- TheColumnLocation
regionIndex
- The index of the region to add.- Returns:
- A new or re-usable column region appropriate for this source and the supplied parameters. A null value may be returned, which should be interpreted to mean use a special null column, which has size() 0 and is full of the appropriate "null" value for the column's type.
-
getPartitionValueFactory
Description copied from interface:PartitioningRegionedSource
Get the factory for converting locations to partition values- Specified by:
getPartitionValueFactory
in interfacePartitioningRegionedSource
- Returns:
- the factory
-
addRegion
@OverridingMethodsMustInvokeSuper public int addRegion(@NotNull com.illumon.dataobjects.ColumnDefinition<?> columnDefinition, @NotNull ColumnLocation columnLocation, @NotNull SourceTableColumnInstructions instructions) Description copied from interface:RegionedColumnSource
Add a region to this regioned column source. Elements in this region are ordered after elements in other regions added previously.- Specified by:
addRegion
in interfaceRegionedColumnSource<DATA_TYPE>
- Parameters:
columnDefinition
- The column definition for this column source (potentially varies by region)columnLocation
- The column location for the region being added- Returns:
- The index assigned to the added region
-
getRegionCount
public final int getRegionCount()Description copied from interface:RegionedPageStore
Get the number of regions.- Specified by:
getRegionCount
in interfaceRegionedPageStore<DATA_TYPE,
ATTR extends Attributes.Values, REGION_TYPE extends ColumnRegion<ATTR>> - Returns:
- The number of regions that have been added
-
getRegion
Description copied from interface:RegionedPageStore
Map from a region index to its corresponding region.- Specified by:
getRegion
in interfaceRegionedPageStore<DATA_TYPE,
ATTR extends Attributes.Values, REGION_TYPE extends ColumnRegion<ATTR>> - Parameters:
regionIndex
- The region index- Returns:
- The region for the supplied region index
-
releaseCachedResources
@OverridingMethodsMustInvokeSuper public void releaseCachedResources()Description copied from interface:ColumnSource
Release any resources held for caching purposes. Implementations need not guarantee that concurrent accesses are correct, as the purpose of this method is to ensure cleanup for column sources that will no longer be used.- Specified by:
releaseCachedResources
in interfaceColumnSource<DATA_TYPE>
- Specified by:
releaseCachedResources
in interfaceReleasable
-
getNullRegion
-