Package io.deephaven.engine.table.impl.naturaljoin

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

Fields

Modifier and Type	Field	Description
protected final ChunkType[]	chunkTypes
protected ImmutableObjectArraySource<WritableRowSet>	leftRowSet
protected final WritableColumnSource<?>[]	mainKeySources
protected ImmutableLongArraySource	modifiedTrackerCookieSource
protected long	numEntries
protected ImmutableLongArraySource	rightRowKey
protected int	tableSize

Fields inherited from class io.deephaven.engine.table.impl.StaticNaturalJoinStateManager

DUPLICATE_RIGHT_VALUE, keySourcesForErrorMessages, NO_RIGHT_ENTRY_VALUE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RightIncrementalNaturalJoinStateManagerTypedBase(ColumnSource<?>[] tableKeySources, ColumnSource<?>[] keySourcesForErrorMessages, int tableSize, double maximumLoadFactor)

Method Summary

Modifier and Type	Method	Description
protected 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)
WritableRowRedirection	buildRowRedirectionFromHashSlot(QueryTable leftTable, boolean exactMatch, RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc, JoinControl.RedirectionType redirectionType)
WritableRowRedirection	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)
RowSet	getLeftIndex(int slot)
long	getRightIndex(int slot)
protected int	hashToTableLocation(int hash)
String	keyString(int slot)
RightIncrementalNaturalJoinStateManager.InitialBuildContext	makeInitialBuildContext(Table leftTable)
TypedHasherUtil.BuildOrProbeContext.ProbeContext	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

protected final ChunkType[] chunkTypes

mainKeySources

protected final WritableColumnSource<?>[] mainKeySources

leftRowSet

protected ImmutableObjectArraySource<WritableRowSet> leftRowSet

rightRowKey

protected ImmutableLongArraySource rightRowKey

modifiedTrackerCookieSource

protected ImmutableLongArraySource 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 class RightIncrementalNaturalJoinStateManager

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

public RowSet getLeftIndex(int slot)

keyString

public String keyString(int slot)

buildFromLeftSide

public void buildFromLeftSide(Table leftTable,
 ColumnSource<?>[] leftSources,
 RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc)

Specified by:

buildFromLeftSide in class RightIncrementalNaturalJoinStateManager

buildFromLeftSide

protected abstract void buildFromLeftSide(RowSequence rowSequence,
 Chunk[] sourceKeyChunks)

convertLeftDataIndex

public void convertLeftDataIndex(int groupingSize,
 RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc,
 ColumnSource<RowSet> rowSetSource)

Specified by:

convertLeftDataIndex in class RightIncrementalNaturalJoinStateManager

addRightSide

public void addRightSide(RowSequence rightRowSet,
 ColumnSource<?>[] rightSources)

Specified by:

addRightSide in class RightIncrementalNaturalJoinStateManager

addRightSide

protected abstract void addRightSide(RowSequence rowSequence,
 Chunk[] sourceKeyChunks)

buildRowRedirectionFromHashSlot

public WritableRowRedirection buildRowRedirectionFromHashSlot(QueryTable leftTable,
 boolean exactMatch,
 RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc,
 JoinControl.RedirectionType redirectionType)

Specified by:

buildRowRedirectionFromHashSlot in class RightIncrementalNaturalJoinStateManager

buildRowRedirectionFromHashSlotIndexed

public WritableRowRedirection buildRowRedirectionFromHashSlotIndexed(QueryTable leftTable,
 ColumnSource<RowSet> rowSetSource,
 int groupingSize,
 boolean exactMatch,
 RightIncrementalNaturalJoinStateManager.InitialBuildContext ibc,
 JoinControl.RedirectionType redirectionType)

Specified by:

buildRowRedirectionFromHashSlotIndexed in class RightIncrementalNaturalJoinStateManager

applyRightShift

public void applyRightShift(Context pc,
 ColumnSource<?>[] rightSources,
 RowSet shiftedRowSet,
 long shiftDelta,
 @NotNull
 @NotNull NaturalJoinModifiedSlotTracker modifiedSlotTracker)

Specified by:

applyRightShift in class RightIncrementalNaturalJoinStateManager

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 class RightIncrementalNaturalJoinStateManager

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 class RightIncrementalNaturalJoinStateManager

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 class RightIncrementalNaturalJoinStateManager

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 class StaticNaturalJoinStateManager

makeInitialBuildContext

public RightIncrementalNaturalJoinStateManager.InitialBuildContext makeInitialBuildContext(Table leftTable)

Specified by:

makeInitialBuildContext in class RightIncrementalNaturalJoinStateManager