Package io.deephaven.engine.table.impl.multijoin

Class StaticMultiJoinStateManagerTypedBase

java.lang.Object

io.deephaven.engine.table.impl.multijoin.StaticMultiJoinStateManagerTypedBase

All Implemented Interfaces:

MultiJoinStateManager

public abstract class StaticMultiJoinStateManagerTypedBase
extends Object
implements MultiJoinStateManager

Field Summary

Fields

Modifier and Type	Field	Description
protected final ChunkType[]	chunkTypes	The keys for our hash entries.
static final int	EMPTY_OUTPUT_ROW
protected final ColumnSource<?>[]	keySourcesForErrorMessages
protected final WritableColumnSource<?>[]	mainKeySources
static final long	NO_REDIRECTION
protected int	numEntries	The number of entries in our hash table in use.
protected final WritableColumnSource[]	outputKeySources	The output sources representing the keys of our joined table.
protected ImmutableIntArraySource	slotToOutputRow	Store sentinel information and maps hash slots to output row keys.
protected int	tableSize	The number of slots in our hash table.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	StaticMultiJoinStateManagerTypedBase(ColumnSource<?>[] tableKeySources, ColumnSource<?>[] keySourcesForErrorMessages, int tableSize, double maximumLoadFactor)

Method Summary

Modifier and Type	Method	Description
void	build(Table table, ColumnSource<?>[] keySources, int tableNumber)	Add the given table to this multiJoin result.
protected abstract void	buildFromTable(RowSequence rowSequence, Chunk<Values>[] sourceKeyChunks, LongArraySource tableRedirSource, long tableNumber)
protected void	buildTable(TypedHasherUtil.BuildOrProbeContext.BuildContext bc, RowSequence buildRows, ColumnSource<?>[] buildSources, TypedHasherUtil.BuildHandler buildHandler)
void	doRehash(int nextChunkSize)
void	ensureTableCapacity(int tables)	Ensure that this state manager can handle numTables tables as constituents of the multiJoin.
ColumnSource<?>[]	getKeyHashTableSources()	Get the hash table column sources for the result table.
long	getResultSize()	Get the number of rows in the result table
RowRedirection	getRowRedirectionForTable(int tableNumber)	Get the result row redirection for a given table
protected int	hashToTableLocation(int hash)
protected String	keyString(Chunk<Values>[] sourceKeyChunks, int chunkPosition)	produce a pretty key for error messages.
protected abstract void	rehashInternalFull(int oldSize)
boolean	rehashRequired(int nextChunkSize)
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

keySourcesForErrorMessages

protected final ColumnSource<?>[] keySourcesForErrorMessages

NO_REDIRECTION

public static final long NO_REDIRECTION

See Also:

• Constant Field Values

EMPTY_OUTPUT_ROW

public static final int EMPTY_OUTPUT_ROW

See Also:

• Constant Field Values

tableSize

protected int tableSize

The number of slots in our hash table.

numEntries

protected int numEntries

The number of entries in our hash table in use.

chunkTypes

protected final ChunkType[] chunkTypes

The keys for our hash entries.

mainKeySources

protected final WritableColumnSource<?>[] mainKeySources

outputKeySources

protected final WritableColumnSource[] outputKeySources

The output sources representing the keys of our joined table.

slotToOutputRow

protected ImmutableIntArraySource slotToOutputRow

Store sentinel information and maps hash slots to output row keys.

Constructor Details

StaticMultiJoinStateManagerTypedBase

protected StaticMultiJoinStateManagerTypedBase(ColumnSource<?>[] tableKeySources,
 ColumnSource<?>[] keySourcesForErrorMessages,
 int tableSize,
 double maximumLoadFactor)

Method Details

build

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

Description copied from interface: MultiJoinStateManager

Add the given table to this multiJoin result.

Specified by:

build in interface MultiJoinStateManager

Parameters:

table - the table to add

keySources - the column sources that contain the keys

tableNumber - the table number for which we are adding rows

buildFromTable

protected abstract void buildFromTable(RowSequence rowSequence,
 Chunk<Values>[] sourceKeyChunks,
 LongArraySource tableRedirSource,
 long tableNumber)

buildTable

protected void buildTable(TypedHasherUtil.BuildOrProbeContext.BuildContext bc,
 RowSequence buildRows,
 ColumnSource<?>[] buildSources,
 TypedHasherUtil.BuildHandler buildHandler)

doRehash

public void doRehash(int nextChunkSize)

rehashRequired

public boolean rehashRequired(int nextChunkSize)

rehashInternalFull

protected abstract void rehashInternalFull(int oldSize)

hashToTableLocation

protected int hashToTableLocation(int hash)

keyString

protected String keyString(Chunk<Values>[] sourceKeyChunks,
 int chunkPosition)

produce a pretty key for error messages.

getResultSize

public long getResultSize()

Description copied from interface: MultiJoinStateManager

Get the number of rows in the result table

Specified by:

getResultSize in interface MultiJoinStateManager

Returns:

the number of rows in the result table

getKeyHashTableSources

public ColumnSource<?>[] getKeyHashTableSources()

Description copied from interface: MultiJoinStateManager

Get the hash table column sources for the result table. These are used as the key columns of our result.

Specified by:

getKeyHashTableSources in interface MultiJoinStateManager

getRowRedirectionForTable

public RowRedirection getRowRedirectionForTable(int tableNumber)

Description copied from interface: MultiJoinStateManager

Get the result row redirection for a given table

Specified by:

getRowRedirectionForTable in interface MultiJoinStateManager

Parameters:

tableNumber - the table to fetch

Returns:

the row redirection for the table

ensureTableCapacity

public void ensureTableCapacity(int tables)

Description copied from interface: MultiJoinStateManager

Ensure that this state manager can handle numTables tables as constituents of the multiJoin.

Specified by:

ensureTableCapacity in interface MultiJoinStateManager

Parameters:

tables - the number of tables that participate

setTargetLoadFactor

public void setTargetLoadFactor(double targetLoadFactor)

Specified by:

setTargetLoadFactor in interface MultiJoinStateManager

setMaximumLoadFactor

public void setMaximumLoadFactor(double maximumLoadFactor)

Specified by:

setMaximumLoadFactor in interface MultiJoinStateManager