Class RightIncrementalNaturalJoinStateManagerTypedBase
java.lang.Object
io.deephaven.engine.table.impl.StaticNaturalJoinStateManager
io.deephaven.engine.table.impl.RightIncrementalNaturalJoinStateManager
io.deephaven.engine.table.impl.naturaljoin.RightIncrementalNaturalJoinStateManagerTypedBase
- All Implemented Interfaces:
IncrementalNaturalJoinStateManager
public abstract class RightIncrementalNaturalJoinStateManagerTypedBase
extends RightIncrementalNaturalJoinStateManager
-
Nested Class Summary
Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.RightIncrementalNaturalJoinStateManager
RightIncrementalNaturalJoinStateManager.InitialBuildContext
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final ChunkType[]
protected ImmutableObjectArraySource<WritableRowSet>
protected final WritableColumnSource<?>[]
protected ImmutableLongArraySource
protected long
protected ImmutableLongArraySource
protected int
Fields inherited from class io.deephaven.engine.table.impl.StaticNaturalJoinStateManager
DUPLICATE_RIGHT_VALUE, keySourcesForErrorMessages, NO_RIGHT_ENTRY_VALUE
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
RightIncrementalNaturalJoinStateManagerTypedBase
(ColumnSource<?>[] tableKeySources, ColumnSource<?>[] keySourcesForErrorMessages, int tableSize, double maximumLoadFactor) -
Method Summary
Modifier and TypeMethodDescriptionprotected abstract void
addRightSide
(RowSequence rowSequence, Chunk[] sourceKeyChunks) protected abstract void
addRightSide
(RowSequence rowSequence, Chunk[] sourceKeyChunks, NaturalJoinModifiedSlotTracker modifiedSlotTracker) void
addRightSide
(RowSequence rightRowSet, ColumnSource<?>[] rightSources) void
addRightSide
(Context pc, RowSequence rightRowSet, ColumnSource<?>[] rightSources, @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) protected abstract void
applyRightShift
(RowSequence rowSequence, Chunk[] sourceKeyChunks, long shiftDelta, NaturalJoinModifiedSlotTracker modifiedSlotTracker) void
applyRightShift
(Context pc, ColumnSource<?>[] rightSources, RowSet shiftedRowSet, long shiftDelta, @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) protected abstract void
buildFromLeftSide
(RowSequence rowSequence, Chunk[] sourceKeyChunks) void
buildFromLeftSide
(Table leftTable, ColumnSource<?>[] leftSources, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc) buildRowRedirectionFromHashSlot
(QueryTable leftTable, boolean exactMatch, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc, JoinControl.RedirectionType redirectionType) buildRowRedirectionFromHashSlotIndexed
(QueryTable leftTable, ColumnSource<RowSet> rowSetSource, int groupingSize, boolean exactMatch, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc, JoinControl.RedirectionType redirectionType) protected void
buildTable
(TypedHasherUtil.BuildOrProbeContext.BuildContext bc, RowSequence buildRows, ColumnSource<?>[] buildSources, TypedHasherUtil.BuildHandler buildHandler) void
convertLeftDataIndex
(int groupingSize, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc, ColumnSource<RowSet> rowSetSource) protected void
decorateLeftSide
(RowSet leftRowSet, ColumnSource<?>[] leftSources, LongArraySource leftRedirections) void
doRehash
(int nextChunkSize) getLeftIndex
(int slot) long
getRightIndex
(int slot) protected int
hashToTableLocation
(int hash) keyString
(int slot) makeInitialBuildContext
(Table leftTable) makeProbeContext
(ColumnSource<?>[] buildSources, long maxSize) protected abstract void
modifyByRight
(RowSequence rowSequence, Chunk[] sourceKeyChunks, NaturalJoinModifiedSlotTracker modifiedSlotTracker) void
modifyByRight
(Context pc, RowSet modified, ColumnSource<?>[] rightSources, @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) protected void
probeTable
(TypedHasherUtil.BuildOrProbeContext.ProbeContext pc, RowSequence probeRows, boolean usePrev, ColumnSource<?>[] probeSources, TypedHasherUtil.ProbeHandler handler) protected abstract void
rehashInternalFull
(int oldSize) boolean
rehashRequired
(int nextChunkSize) protected abstract void
removeRight
(RowSequence rowSequence, Chunk[] sourceKeyChunks, NaturalJoinModifiedSlotTracker modifiedSlotTracker) void
removeRight
(Context pc, RowSequence rightRowSet, ColumnSource<?>[] rightSources, @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) Methods inherited from class io.deephaven.engine.table.impl.StaticNaturalJoinStateManager
buildRowRedirection, checkExactMatch, extractKeyStringFromSourceTable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.deephaven.engine.table.impl.IncrementalNaturalJoinStateManager
checkExactMatch
-
Field Details
-
tableSize
protected int tableSize -
numEntries
protected long numEntries -
chunkTypes
-
mainKeySources
-
leftRowSet
-
rightRowKey
-
modifiedTrackerCookieSource
-
-
Constructor Details
-
RightIncrementalNaturalJoinStateManagerTypedBase
protected RightIncrementalNaturalJoinStateManagerTypedBase(ColumnSource<?>[] tableKeySources, ColumnSource<?>[] keySourcesForErrorMessages, int tableSize, double maximumLoadFactor)
-
-
Method Details
-
makeProbeContext
public TypedHasherUtil.BuildOrProbeContext.ProbeContext makeProbeContext(ColumnSource<?>[] buildSources, long maxSize) - Specified by:
makeProbeContext
in classRightIncrementalNaturalJoinStateManager
-
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) -
doRehash
public void doRehash(int nextChunkSize) -
rehashRequired
public boolean rehashRequired(int nextChunkSize) -
rehashInternalFull
protected abstract void rehashInternalFull(int oldSize) -
hashToTableLocation
protected int hashToTableLocation(int hash) -
getRightIndex
public long getRightIndex(int slot) -
getLeftIndex
-
keyString
-
buildFromLeftSide
public void buildFromLeftSide(Table leftTable, ColumnSource<?>[] leftSources, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc) - Specified by:
buildFromLeftSide
in classRightIncrementalNaturalJoinStateManager
-
buildFromLeftSide
-
convertLeftDataIndex
public void convertLeftDataIndex(int groupingSize, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc, ColumnSource<RowSet> rowSetSource) - Specified by:
convertLeftDataIndex
in classRightIncrementalNaturalJoinStateManager
-
addRightSide
- Specified by:
addRightSide
in classRightIncrementalNaturalJoinStateManager
-
addRightSide
-
buildRowRedirectionFromHashSlot
public WritableRowRedirection buildRowRedirectionFromHashSlot(QueryTable leftTable, boolean exactMatch, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc, JoinControl.RedirectionType redirectionType) - Specified by:
buildRowRedirectionFromHashSlot
in classRightIncrementalNaturalJoinStateManager
-
buildRowRedirectionFromHashSlotIndexed
public WritableRowRedirection buildRowRedirectionFromHashSlotIndexed(QueryTable leftTable, ColumnSource<RowSet> rowSetSource, int groupingSize, boolean exactMatch, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc, JoinControl.RedirectionType redirectionType) - Specified by:
buildRowRedirectionFromHashSlotIndexed
in classRightIncrementalNaturalJoinStateManager
-
applyRightShift
public void applyRightShift(Context pc, ColumnSource<?>[] rightSources, RowSet shiftedRowSet, long shiftDelta, @NotNull @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) - Specified by:
applyRightShift
in classRightIncrementalNaturalJoinStateManager
-
applyRightShift
protected abstract void applyRightShift(RowSequence rowSequence, Chunk[] sourceKeyChunks, long shiftDelta, NaturalJoinModifiedSlotTracker modifiedSlotTracker) -
modifyByRight
public void modifyByRight(Context pc, RowSet modified, ColumnSource<?>[] rightSources, @NotNull @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) - Specified by:
modifyByRight
in classRightIncrementalNaturalJoinStateManager
-
modifyByRight
protected abstract void modifyByRight(RowSequence rowSequence, Chunk[] sourceKeyChunks, NaturalJoinModifiedSlotTracker modifiedSlotTracker) -
removeRight
public void removeRight(Context pc, RowSequence rightRowSet, ColumnSource<?>[] rightSources, @NotNull @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) - Specified by:
removeRight
in classRightIncrementalNaturalJoinStateManager
-
removeRight
protected abstract void removeRight(RowSequence rowSequence, Chunk[] sourceKeyChunks, NaturalJoinModifiedSlotTracker modifiedSlotTracker) -
addRightSide
public void addRightSide(Context pc, RowSequence rightRowSet, ColumnSource<?>[] rightSources, @NotNull @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker) - Specified by:
addRightSide
in classRightIncrementalNaturalJoinStateManager
-
addRightSide
protected abstract void addRightSide(RowSequence rowSequence, Chunk[] sourceKeyChunks, NaturalJoinModifiedSlotTracker modifiedSlotTracker) -
decorateLeftSide
protected void decorateLeftSide(RowSet leftRowSet, ColumnSource<?>[] leftSources, LongArraySource leftRedirections) - Specified by:
decorateLeftSide
in classStaticNaturalJoinStateManager
-
makeInitialBuildContext
public RightIncrementalNaturalJoinStateManager.InitialBuildContext makeInitialBuildContext(Table leftTable) - Specified by:
makeInitialBuildContext
in classRightIncrementalNaturalJoinStateManager
-