Package io.deephaven.engine.table.impl.asofjoin

Class RightIncrementalHashedAsOfJoinStateManager

java.lang.Object

io.deephaven.engine.table.impl.RightIncrementalAsOfJoinStateManager

io.deephaven.engine.table.impl.asofjoin.RightIncrementalHashedAsOfJoinStateManager

Direct Known Subclasses:

RightIncrementalAsOfJoinStateManagerTypedBase

public abstract class RightIncrementalHashedAsOfJoinStateManager
extends RightIncrementalAsOfJoinStateManager

Field Summary

Fields

Modifier and Type	Field	Description
static final byte	ENTRY_LEFT_IS_BUILDER
static final byte	ENTRY_LEFT_IS_EMPTY
static final byte	ENTRY_LEFT_IS_ROWSET
static final byte	ENTRY_LEFT_IS_SSA
static final byte	ENTRY_LEFT_MASK
static final byte	ENTRY_RIGHT_IS_BUILDER
static final byte	ENTRY_RIGHT_IS_EMPTY
static final byte	ENTRY_RIGHT_IS_ROWSET
static final byte	ENTRY_RIGHT_IS_SSA
static final byte	ENTRY_RIGHT_MASK

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

keySourcesForErrorMessages

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RightIncrementalHashedAsOfJoinStateManager(ColumnSource<?>[] keySourcesForErrorMessages)

Method Summary

Modifier and Type	Method	Description
abstract void	addTombstoneCandidate(int slot)	Record a slot whose left or right side may have become empty during this cycle, so that releaseEmptyBuckets() can release it.
protected void	addToSequentialBuilder(long slot, @NotNull ObjectArraySource<RowSetBuilderSequential> sequentialBuilders, long indexKey)
abstract int	buildAdditions(boolean isLeftSide, RowSet additions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract int	buildFromLeftSide(RowSequence leftRowSet, ColumnSource<?>[] leftSources, @NotNull IntegerArraySource addedSlots)
abstract int	buildFromRightSide(RowSequence rightRowSet, ColumnSource<?>[] rightSources, @NotNull IntegerArraySource addedSlots, int usedSlots)
abstract void	ensureTombstoneCandidateCapacity(int additionalCandidates)	Reserve room for additionalCandidates more calls to addTombstoneCandidate(int) in this cycle.
abstract int	gatherModifications(RowSet restampAdditions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract int	gatherShiftRowSet(RowSet restampAdditions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract int	gatherShiftRowSet(Context probeContext, RowSet rowSet, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)	Gather the rows of rowSet by slot, as gatherShiftRowSet(RowSet, ColumnSource[], IntegerArraySource, ObjectArraySource) does, reusing a context from makeProbeContext(io.deephaven.engine.table.ColumnSource<?>[], long) so that a caller probing many row sets in one cycle allocates it once.
abstract WritableRowSet	getAndClearLeftRowSet(int slot)
abstract WritableRowSet	getLeftRowSet(int slot)
abstract SegmentedSortedArray	getLeftSsa(int slot)
abstract SegmentedSortedArray	getLeftSsa(int slot, Function<RowSet,SegmentedSortedArray> ssaFactory)
abstract SegmentedSortedArray	getLeftSsaOrRowSet(int slot, org.apache.commons.lang3.mutable.MutableObject<WritableRowSet> indexOutput)
abstract long	getNumEntries()	The number of live buckets, which bounds the number of distinct slots any probe can report and therefore the capacity the per-slot output arrays need.
protected byte	getRightEntryType(byte entryType)
abstract WritableRowSet	getRightRowSet(int slot)
abstract SegmentedSortedArray	getRightSsa(int slot)
abstract SegmentedSortedArray	getRightSsa(int slot, Function<RowSet,SegmentedSortedArray> ssaFactory)
abstract SegmentedSortedArray	getRightSsaOrRowSet(int slot, org.apache.commons.lang3.mutable.MutableObject<WritableRowSet> indexOutput)
abstract byte	getState(int slot)
abstract int	getTableSize()
protected byte	leftEntryAsRightType(byte entryType)
abstract Context	makeProbeContext(ColumnSource<?>[] probeSources, long maxSize)	Make a probe context for gatherShiftRowSet(Context, RowSet, ColumnSource[], IntegerArraySource, ObjectArraySource).
abstract int	markForRemoval(RowSet restampRemovals, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract void	populateLeftRowSetsFromIndexTable(IntegerArraySource slots, int slotCount, ColumnSource<RowSet> rowSetSource)
abstract void	populateRightRowSetsFromIndexTable(IntegerArraySource slots, int slotCount, ColumnSource<RowSet> rowSetSource)
abstract int	probeAdditions(RowSet restampAdditions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract void	probeRightInitial(RowSequence rowsToProbe, ColumnSource<?>[] rightSources)
abstract void	releaseEmptyBuckets()	Release every candidate bucket whose left and right sides are both empty, replacing it with a tombstone that a later build may reuse.
abstract void	setLeftRowSet(int slot, RowSet rowSet)
abstract void	setRightRowSet(int slot, RowSet rowSet)

Methods inherited from class io.deephaven.engine.table.impl.RightIncrementalAsOfJoinStateManager

extractKeyStringFromSourceTable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ENTRY_RIGHT_MASK

public static final byte ENTRY_RIGHT_MASK

See Also:

• Constant Field Values

ENTRY_RIGHT_IS_EMPTY

public static final byte ENTRY_RIGHT_IS_EMPTY

See Also:

• Constant Field Values

ENTRY_RIGHT_IS_BUILDER

public static final byte ENTRY_RIGHT_IS_BUILDER

See Also:

• Constant Field Values

ENTRY_RIGHT_IS_SSA

public static final byte ENTRY_RIGHT_IS_SSA

See Also:

• Constant Field Values

ENTRY_RIGHT_IS_ROWSET

public static final byte ENTRY_RIGHT_IS_ROWSET

See Also:

• Constant Field Values

ENTRY_LEFT_MASK

public static final byte ENTRY_LEFT_MASK

See Also:

• Constant Field Values

ENTRY_LEFT_IS_EMPTY

public static final byte ENTRY_LEFT_IS_EMPTY

See Also:

• Constant Field Values

ENTRY_LEFT_IS_BUILDER

public static final byte ENTRY_LEFT_IS_BUILDER

See Also:

• Constant Field Values

ENTRY_LEFT_IS_SSA

public static final byte ENTRY_LEFT_IS_SSA

See Also:

• Constant Field Values

ENTRY_LEFT_IS_ROWSET

public static final byte ENTRY_LEFT_IS_ROWSET

See Also:

• Constant Field Values

Constructor Details

RightIncrementalHashedAsOfJoinStateManager

protected RightIncrementalHashedAsOfJoinStateManager(ColumnSource<?>[] keySourcesForErrorMessages)

Method Details

addToSequentialBuilder

protected void addToSequentialBuilder(long slot,
 @NotNull
 @NotNull ObjectArraySource<RowSetBuilderSequential> sequentialBuilders,
 long indexKey)

getNumEntries

public abstract long getNumEntries()

The number of live buckets, which bounds the number of distinct slots any probe can report and therefore the capacity the per-slot output arrays need. A bucket released by releaseEmptyBuckets() is not counted.

Returns:

the number of live buckets this manager holds

ensureTombstoneCandidateCapacity

public abstract void ensureTombstoneCandidateCapacity(int additionalCandidates)

Reserve room for additionalCandidates more calls to addTombstoneCandidate(int) in this cycle.

Parameters:

additionalCandidates - the number of candidates that may be added

addTombstoneCandidate

public abstract void addTombstoneCandidate(int slot)

Record a slot whose left or right side may have become empty during this cycle, so that releaseEmptyBuckets() can release it. Room for the candidate must already have been reserved with ensureTombstoneCandidateCapacity(int).

Parameters:

slot - the slot, as reported by a build or probe of this cycle

releaseEmptyBuckets

public abstract void releaseEmptyBuckets()

Release every candidate bucket whose left and right sides are both empty, replacing it with a tombstone that a later build may reuse. The slot numbers reported by this cycle's builds and probes must no longer be in use, as a released slot may hold a different key after the next build.

leftEntryAsRightType

protected byte leftEntryAsRightType(byte entryType)

getRightEntryType

protected byte getRightEntryType(byte entryType)

buildFromLeftSide

public abstract int buildFromLeftSide(RowSequence leftRowSet,
 ColumnSource<?>[] leftSources,
 @NotNull
 @NotNull IntegerArraySource addedSlots)

buildFromRightSide

public abstract int buildFromRightSide(RowSequence rightRowSet,
 ColumnSource<?>[] rightSources,
 @NotNull
 @NotNull IntegerArraySource addedSlots,
 int usedSlots)

probeRightInitial

public abstract void probeRightInitial(RowSequence rowsToProbe,
 ColumnSource<?>[] rightSources)

probeAdditions

public abstract int probeAdditions(RowSet restampAdditions,
 ColumnSource<?>[] sources,
 IntegerArraySource slots,
 ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)

buildAdditions

public abstract int buildAdditions(boolean isLeftSide,
 RowSet additions,
 ColumnSource<?>[] sources,
 IntegerArraySource slots,
 ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)

getRightSsa

public abstract SegmentedSortedArray getRightSsa(int slot)

getRightSsa

public abstract SegmentedSortedArray getRightSsa(int slot,
 Function<RowSet,SegmentedSortedArray> ssaFactory)

getLeftSsa

public abstract SegmentedSortedArray getLeftSsa(int slot)

getLeftSsa

public abstract SegmentedSortedArray getLeftSsa(int slot,
 Function<RowSet,SegmentedSortedArray> ssaFactory)

getLeftSsaOrRowSet

public abstract SegmentedSortedArray getLeftSsaOrRowSet(int slot,
 org.apache.commons.lang3.mutable.MutableObject<WritableRowSet> indexOutput)

getRightSsaOrRowSet

public abstract SegmentedSortedArray getRightSsaOrRowSet(int slot,
 org.apache.commons.lang3.mutable.MutableObject<WritableRowSet> indexOutput)

setRightRowSet

public abstract void setRightRowSet(int slot,
 RowSet rowSet)

setLeftRowSet

public abstract void setLeftRowSet(int slot,
 RowSet rowSet)

getLeftRowSet

public abstract WritableRowSet getLeftRowSet(int slot)

getRightRowSet

public abstract WritableRowSet getRightRowSet(int slot)

populateRightRowSetsFromIndexTable

public abstract void populateRightRowSetsFromIndexTable(IntegerArraySource slots,
 int slotCount,
 ColumnSource<RowSet> rowSetSource)

populateLeftRowSetsFromIndexTable

public abstract void populateLeftRowSetsFromIndexTable(IntegerArraySource slots,
 int slotCount,
 ColumnSource<RowSet> rowSetSource)

getAndClearLeftRowSet

public abstract WritableRowSet getAndClearLeftRowSet(int slot)

markForRemoval

public abstract int markForRemoval(RowSet restampRemovals,
 ColumnSource<?>[] sources,
 IntegerArraySource slots,
 ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)

gatherShiftRowSet

public abstract int gatherShiftRowSet(RowSet restampAdditions,
 ColumnSource<?>[] sources,
 IntegerArraySource slots,
 ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)

makeProbeContext

public abstract Context makeProbeContext(ColumnSource<?>[] probeSources,
 long maxSize)

Make a probe context for gatherShiftRowSet(Context, RowSet, ColumnSource[], IntegerArraySource, ObjectArraySource).

Parameters:

probeSources - the key sources that will be probed

maxSize - the largest row set that will be probed with the context

Returns:

a context the caller must close

gatherShiftRowSet

public abstract int gatherShiftRowSet(Context probeContext,
 RowSet rowSet,
 ColumnSource<?>[] sources,
 IntegerArraySource slots,
 ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)

Gather the rows of rowSet by slot, as gatherShiftRowSet(RowSet, ColumnSource[], IntegerArraySource, ObjectArraySource) does, reusing a context from makeProbeContext(io.deephaven.engine.table.ColumnSource<?>[], long) so that a caller probing many row sets in one cycle allocates it once.

gatherModifications

public abstract int gatherModifications(RowSet restampAdditions,
 ColumnSource<?>[] sources,
 IntegerArraySource slots,
 ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)

getState

public abstract byte getState(int slot)

getTableSize

public abstract int getTableSize()