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
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 int	gatherModifications(RowSet restampAdditions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract int	gatherShiftRowSet(RowSet restampAdditions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
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)
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 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	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)

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)

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()