Package com.illumon.iris.db.v2

Class RightIncrementalChunkedAsOfJoinStateManager

java.lang.Object

com.illumon.iris.db.v2.RightIncrementalChunkedAsOfJoinStateManager

public class RightIncrementalChunkedAsOfJoinStateManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final double	DEFAULT_MAX_LOAD_FACTOR
static final double	DEFAULT_TARGET_LOAD_FACTOR
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

Method Summary

Modifier and Type	Method	Description
int	buildAdditions(boolean isLeftSide, Index additions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)
void	doRehash(com.illumon.iris.db.v2.RightIncrementalChunkedAsOfJoinStateManager.BuildContext bc, LongArraySource addedSlots)
int	gatherModifications(Index restampAdditions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)
int	gatherShiftIndex(Index restampAdditions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)
Index	getLeftIndex(long slot)
SegmentedSortedArray	getLeftSsa(long slot)
SegmentedSortedArray	getLeftSsa(long slot, Function<Index,SegmentedSortedArray> ssaFactory)
SegmentedSortedArray	getLeftSsaOrIndex(long slot, org.apache.commons.lang3.mutable.MutableObject<Index> indexOutput)
int	getOverflowSize()
Index	getRightIndex(long slot)
SegmentedSortedArray	getRightSsa(long slot)
SegmentedSortedArray	getRightSsa(long slot, Function<Index,SegmentedSortedArray> ssaFactory)
SegmentedSortedArray	getRightSsaOrIndex(long slot, org.apache.commons.lang3.mutable.MutableObject<Index> indexOutput)
byte	getState(long slot)
int	getTableSize()
int	markForRemoval(Index restampRemovals, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)
int	probeAdditions(Index restampAdditions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)
boolean	rehashRequired()
void	setLeftIndex(long slot, Index index)
void	setMaximumLoadFactor(double maximumLoadFactor)
void	setRightIndex(long slot, Index index)
void	setTargetLoadFactor(double targetLoadFactor)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MAX_LOAD_FACTOR

public static final double DEFAULT_MAX_LOAD_FACTOR

See Also:

• Constant Field Values

DEFAULT_TARGET_LOAD_FACTOR

public static final double DEFAULT_TARGET_LOAD_FACTOR

See Also:

• Constant Field Values

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

Method Details

buildAdditions

public int buildAdditions(boolean isLeftSide,
 Index additions,
 ColumnSource<?>[] sources,
 LongArraySource slots,
 ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)

doRehash

public void doRehash(com.illumon.iris.db.v2.RightIncrementalChunkedAsOfJoinStateManager.BuildContext bc,
 LongArraySource addedSlots)

rehashRequired

public boolean rehashRequired()

setTargetLoadFactor

public void setTargetLoadFactor(double targetLoadFactor)

setMaximumLoadFactor

public void setMaximumLoadFactor(double maximumLoadFactor)

markForRemoval

public int markForRemoval(Index restampRemovals,
 ColumnSource<?>[] sources,
 LongArraySource slots,
 ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)

probeAdditions

public int probeAdditions(Index restampAdditions,
 ColumnSource<?>[] sources,
 LongArraySource slots,
 ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)

gatherShiftIndex

public int gatherShiftIndex(Index restampAdditions,
 ColumnSource<?>[] sources,
 LongArraySource slots,
 ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)

gatherModifications

public int gatherModifications(Index restampAdditions,
 ColumnSource<?>[] sources,
 LongArraySource slots,
 ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)

getTableSize

public int getTableSize()

getOverflowSize

public int getOverflowSize()

getState

public byte getState(long slot)

getRightSsa

public SegmentedSortedArray getRightSsa(long slot,
 Function<Index,SegmentedSortedArray> ssaFactory)

getRightSsa

public SegmentedSortedArray getRightSsa(long slot)

getRightIndex

public Index getRightIndex(long slot)

getLeftIndex

public Index getLeftIndex(long slot)

setLeftIndex

public void setLeftIndex(long slot,
 Index index)

setRightIndex

public void setRightIndex(long slot,
 Index index)

getLeftSsa

public SegmentedSortedArray getLeftSsa(long slot)

getLeftSsa

public SegmentedSortedArray getLeftSsa(long slot,
 Function<Index,SegmentedSortedArray> ssaFactory)

getLeftSsaOrIndex

public SegmentedSortedArray getLeftSsaOrIndex(long slot,
 org.apache.commons.lang3.mutable.MutableObject<Index> indexOutput)

getRightSsaOrIndex

public SegmentedSortedArray getRightSsaOrIndex(long slot,
 org.apache.commons.lang3.mutable.MutableObject<Index> indexOutput)