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_INDEX
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_INDEX
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	gatherShiftIndex(RowSet restampAdditions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract WritableRowSet	getAndClearLeftIndex(int slot)
abstract WritableRowSet	getLeftIndex(int slot)
abstract SegmentedSortedArray	getLeftSsa(int slot)
abstract SegmentedSortedArray	getLeftSsa(int slot, Function<RowSet,SegmentedSortedArray> ssaFactory)
abstract SegmentedSortedArray	getLeftSsaOrIndex(int slot, org.apache.commons.lang3.mutable.MutableObject<WritableRowSet> indexOutput)
protected byte	getRightEntryType(byte entryType)
abstract WritableRowSet	getRightIndex(int slot)
abstract SegmentedSortedArray	getRightSsa(int slot)
abstract SegmentedSortedArray	getRightSsa(int slot, Function<RowSet,SegmentedSortedArray> ssaFactory)
abstract SegmentedSortedArray	getRightSsaOrIndex(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 int	probeAdditions(RowSet restampAdditions, ColumnSource<?>[] sources, IntegerArraySource slots, ObjectArraySource<RowSetBuilderSequential> sequentialBuilders)
abstract void	probeRightInitial(RowSequence rightIndex, ColumnSource<?>[] rightSources)
abstract void	setLeftIndex(int slot, RowSet rowSet)
abstract void	setRightIndex(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_INDEX

public static final byte ENTRY_RIGHT_IS_INDEX

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_INDEX

public static final byte ENTRY_LEFT_IS_INDEX

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 rightIndex,
 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)

getLeftSsaOrIndex

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

getRightSsaOrIndex

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

setRightIndex

public abstract void setRightIndex(int slot,
 RowSet rowSet)

setLeftIndex

public abstract void setLeftIndex(int slot,
 RowSet rowSet)

getLeftIndex

public abstract WritableRowSet getLeftIndex(int slot)

getRightIndex

public abstract WritableRowSet getRightIndex(int slot)

getAndClearLeftIndex

public abstract WritableRowSet getAndClearLeftIndex(int slot)

markForRemoval

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

gatherShiftIndex

public abstract int gatherShiftIndex(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()