Package com.illumon.iris.db.v2.join

Class IncrementalMultiJoinStateManager

java.lang.Object

com.illumon.iris.db.v2.join.IncrementalMultiJoinStateManager

public class IncrementalMultiJoinStateManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CHUNK_SIZE
static final double	DEFAULT_MAX_LOAD_FACTOR
static final double	DEFAULT_TARGET_LOAD_FACTOR

Method Summary

Modifier and Type	Method	Description
void	applyShift(com.illumon.iris.db.v2.join.IncrementalMultiJoinStateManager.ProbeContext pc, Index index, ColumnSource<?>[] sources, int tableNumber, long shiftDelta, MultiJoinModifiedSlotTracker slotTracker)
void	build(Table table, ColumnSource<?>[] sources, int tableNumber)
void	doRehash(com.illumon.iris.db.v2.join.IncrementalMultiJoinStateManager.BuildContext bc)
void	ensureTableCapacity(int tables)
void	getCurrentRedirections(long slot, long[] redirections)
ColumnSource[]	getKeyHashTableSources()
RedirectionIndex	getRedirectionIndexForTable(int tableNumber)
long	getResultSize()
int	getTableCount()
String	keyString(long slot)
void	processAdded(Index index, ColumnSource<?>[] sources, int tableNumber, MultiJoinModifiedSlotTracker slotTracker, boolean addedForKeyModified)
void	processModified(Index index, ColumnSource<?>[] sources, int tableNumber, MultiJoinModifiedSlotTracker slotTracker)
void	processRemoved(Index index, ColumnSource<?>[] sources, int tableNumber, MultiJoinModifiedSlotTracker slotTracker, boolean removedForKeyModify)
boolean	rehashRequired()
void	setMaximumLoadFactor(double maximumLoadFactor)
void	setTargetLoadFactor(double targetLoadFactor)

Methods inherited from class java.lang.Object

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

Field Details

CHUNK_SIZE

public static final int CHUNK_SIZE

See Also:

• Constant Field Values

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

Method Details

build

public void build(Table table,
 ColumnSource<?>[] sources,
 int tableNumber)

processAdded

public void processAdded(Index index,
 ColumnSource<?>[] sources,
 int tableNumber,
 @Nullable
 MultiJoinModifiedSlotTracker slotTracker,
 boolean addedForKeyModified)

doRehash

public void doRehash(com.illumon.iris.db.v2.join.IncrementalMultiJoinStateManager.BuildContext bc)

rehashRequired

public boolean rehashRequired()

setTargetLoadFactor

public void setTargetLoadFactor(double targetLoadFactor)

setMaximumLoadFactor

public void setMaximumLoadFactor(double maximumLoadFactor)

processRemoved

public void processRemoved(Index index,
 ColumnSource<?>[] sources,
 int tableNumber,
 @NotNull
 MultiJoinModifiedSlotTracker slotTracker,
 boolean removedForKeyModify)

processModified

public void processModified(Index index,
 ColumnSource<?>[] sources,
 int tableNumber,
 @NotNull
 MultiJoinModifiedSlotTracker slotTracker)

applyShift

public void applyShift(com.illumon.iris.db.v2.join.IncrementalMultiJoinStateManager.ProbeContext pc,
 Index index,
 ColumnSource<?>[] sources,
 int tableNumber,
 long shiftDelta,
 @NotNull
 MultiJoinModifiedSlotTracker slotTracker)

getResultSize

public long getResultSize()

getTableCount

public int getTableCount()

ensureTableCapacity

public void ensureTableCapacity(int tables)

getCurrentRedirections

public void getCurrentRedirections(long slot,
 long[] redirections)

getKeyHashTableSources

public ColumnSource[] getKeyHashTableSources()

getRedirectionIndexForTable

public RedirectionIndex getRedirectionIndexForTable(int tableNumber)

keyString

public String keyString(long slot)