Class StaticNaturalJoinStateManagerTypedBase
java.lang.Object
io.deephaven.engine.table.impl.StaticNaturalJoinStateManager
io.deephaven.engine.table.impl.naturaljoin.StaticHashedNaturalJoinStateManager
io.deephaven.engine.table.impl.naturaljoin.StaticNaturalJoinStateManagerTypedBase
public abstract class StaticNaturalJoinStateManagerTypedBase
extends StaticHashedNaturalJoinStateManager
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final ChunkType[]
static final long
static final long
protected final WritableColumnSource[]
protected ImmutableLongArraySource
static final long
protected long
protected int
Fields inherited from class io.deephaven.engine.table.impl.StaticNaturalJoinStateManager
DUPLICATE_RIGHT_VALUE, keySourcesForErrorMessages, NO_RIGHT_ENTRY_VALUE
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
StaticNaturalJoinStateManagerTypedBase
(ColumnSource<?>[] tableKeySources, ColumnSource<?>[] keySourcesForErrorMessages, int tableSize, double maximumLoadFactor) -
Method Summary
Modifier and TypeMethodDescriptionprotected abstract void
buildFromLeftSide
(RowSequence rowSequence, Chunk[] sourceKeyChunks, IntegerArraySource leftHashSlots, long hashSlotOffset) void
buildFromLeftSide
(Table leftTable, ColumnSource<?>[] leftSources, IntegerArraySource leftHashSlots) protected abstract void
buildFromRightSide
(RowSequence rowSequence, Chunk[] sourceKeyChunks) void
buildFromRightSide
(Table rightTable, ColumnSource<?>[] rightSources) buildIndexedRowRedirectionFromHashSlots
(QueryTable leftTable, boolean exactMatch, RowSet indexTableRowSet, IntegerArraySource leftHashSlots, ColumnSource<RowSet> indexRowSets, JoinControl.RedirectionType redirectionType) buildIndexedRowRedirectionFromRedirections
(QueryTable leftTable, boolean exactMatch, RowSet indexTableRowSet, LongArraySource leftRedirections, ColumnSource<RowSet> indexRowSets, JoinControl.RedirectionType redirectionType) buildRowRedirectionFromHashSlot
(QueryTable leftTable, boolean exactMatch, IntegerArraySource leftHashSlots, JoinControl.RedirectionType redirectionType) buildRowRedirectionFromRedirections
(QueryTable leftTable, boolean exactMatch, LongArraySource leftRedirections, JoinControl.RedirectionType redirectionType) protected void
buildTable
(TypedHasherUtil.BuildOrProbeContext.BuildContext bc, RowSequence buildRows, ColumnSource<?>[] buildSources, TypedHasherUtil.BuildHandler buildHandler) protected abstract void
decorateLeftSide
(RowSequence rowSequence, Chunk[] sourceKeyChunks, LongArraySource leftRedirections, long redirectionsOffset) void
decorateLeftSide
(RowSet leftRowSet, ColumnSource<?>[] leftSources, LongArraySource leftRedirections) protected abstract void
decorateWithRightSide
(RowSequence rowSequence, Chunk[] sourceKeyChunks) void
decorateWithRightSide
(Table rightTable, ColumnSource<?>[] rightSources) void
errorOnDuplicatesIndexed
(IntegerArraySource leftHashSlots, long size, ObjectArraySource<RowSet> rowSetSource) void
errorOnDuplicatesSingle
(IntegerArraySource leftHashSlots, long size, RowSet rowSet) boolean
exceedsCapacity
(int nextChunkSize) protected int
hashToTableLocation
(int hash) protected void
probeTable
(TypedHasherUtil.BuildOrProbeContext.ProbeContext pc, RowSequence probeRows, boolean usePrev, ColumnSource<?>[] probeSources, TypedHasherUtil.ProbeHandler handler) Methods inherited from class io.deephaven.engine.table.impl.naturaljoin.StaticHashedNaturalJoinStateManager
buildIndexedRowRedirection, errorOnDuplicates
Methods inherited from class io.deephaven.engine.table.impl.StaticNaturalJoinStateManager
buildRowRedirection, checkExactMatch, extractKeyStringFromSourceTable
-
Field Details
-
NO_RIGHT_STATE_VALUE
public static final long NO_RIGHT_STATE_VALUE- See Also:
-
EMPTY_RIGHT_STATE
public static final long EMPTY_RIGHT_STATE- See Also:
-
DUPLICATE_RIGHT_STATE
public static final long DUPLICATE_RIGHT_STATE- See Also:
-
tableSize
protected int tableSize -
numEntries
protected long numEntries -
chunkTypes
-
mainKeySources
-
mainRightRowKey
-
-
Constructor Details
-
StaticNaturalJoinStateManagerTypedBase
protected StaticNaturalJoinStateManagerTypedBase(ColumnSource<?>[] tableKeySources, ColumnSource<?>[] keySourcesForErrorMessages, int tableSize, double maximumLoadFactor)
-
-
Method Details
-
buildFromLeftSide
public void buildFromLeftSide(Table leftTable, ColumnSource<?>[] leftSources, IntegerArraySource leftHashSlots) - Specified by:
buildFromLeftSide
in classStaticHashedNaturalJoinStateManager
-
buildFromLeftSide
protected abstract void buildFromLeftSide(RowSequence rowSequence, Chunk[] sourceKeyChunks, IntegerArraySource leftHashSlots, long hashSlotOffset) -
buildFromRightSide
- Specified by:
buildFromRightSide
in classStaticHashedNaturalJoinStateManager
-
buildFromRightSide
-
decorateLeftSide
public void decorateLeftSide(RowSet leftRowSet, ColumnSource<?>[] leftSources, LongArraySource leftRedirections) - Specified by:
decorateLeftSide
in classStaticHashedNaturalJoinStateManager
-
decorateLeftSide
protected abstract void decorateLeftSide(RowSequence rowSequence, Chunk[] sourceKeyChunks, LongArraySource leftRedirections, long redirectionsOffset) -
decorateWithRightSide
- Specified by:
decorateWithRightSide
in classStaticHashedNaturalJoinStateManager
-
decorateWithRightSide
-
buildTable
protected void buildTable(TypedHasherUtil.BuildOrProbeContext.BuildContext bc, RowSequence buildRows, ColumnSource<?>[] buildSources, TypedHasherUtil.BuildHandler buildHandler) -
probeTable
protected void probeTable(TypedHasherUtil.BuildOrProbeContext.ProbeContext pc, RowSequence probeRows, boolean usePrev, ColumnSource<?>[] probeSources, TypedHasherUtil.ProbeHandler handler) -
exceedsCapacity
public boolean exceedsCapacity(int nextChunkSize) -
hashToTableLocation
protected int hashToTableLocation(int hash) -
buildRowRedirectionFromHashSlot
public WritableRowRedirection buildRowRedirectionFromHashSlot(QueryTable leftTable, boolean exactMatch, IntegerArraySource leftHashSlots, JoinControl.RedirectionType redirectionType) - Specified by:
buildRowRedirectionFromHashSlot
in classStaticHashedNaturalJoinStateManager
-
buildRowRedirectionFromRedirections
public WritableRowRedirection buildRowRedirectionFromRedirections(QueryTable leftTable, boolean exactMatch, LongArraySource leftRedirections, JoinControl.RedirectionType redirectionType) - Specified by:
buildRowRedirectionFromRedirections
in classStaticHashedNaturalJoinStateManager
-
buildIndexedRowRedirectionFromRedirections
public WritableRowRedirection buildIndexedRowRedirectionFromRedirections(QueryTable leftTable, boolean exactMatch, RowSet indexTableRowSet, LongArraySource leftRedirections, ColumnSource<RowSet> indexRowSets, JoinControl.RedirectionType redirectionType) - Specified by:
buildIndexedRowRedirectionFromRedirections
in classStaticHashedNaturalJoinStateManager
-
buildIndexedRowRedirectionFromHashSlots
public WritableRowRedirection buildIndexedRowRedirectionFromHashSlots(QueryTable leftTable, boolean exactMatch, RowSet indexTableRowSet, IntegerArraySource leftHashSlots, ColumnSource<RowSet> indexRowSets, JoinControl.RedirectionType redirectionType) - Specified by:
buildIndexedRowRedirectionFromHashSlots
in classStaticHashedNaturalJoinStateManager
-
errorOnDuplicatesIndexed
public void errorOnDuplicatesIndexed(IntegerArraySource leftHashSlots, long size, ObjectArraySource<RowSet> rowSetSource) - Overrides:
errorOnDuplicatesIndexed
in classStaticHashedNaturalJoinStateManager
-
errorOnDuplicatesSingle
- Overrides:
errorOnDuplicatesSingle
in classStaticHashedNaturalJoinStateManager
-