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 byte
ENTRY_LEFT_IS_BUILDER
static byte
ENTRY_LEFT_IS_EMPTY
static byte
ENTRY_LEFT_IS_INDEX
static byte
ENTRY_LEFT_IS_SSA
static byte
ENTRY_LEFT_MASK
static byte
ENTRY_RIGHT_IS_BUILDER
static byte
ENTRY_RIGHT_IS_EMPTY
static byte
ENTRY_RIGHT_IS_INDEX
static byte
ENTRY_RIGHT_IS_SSA
static 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)
-
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
-
-
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
-
getRightIndex
-
getLeftIndex
-
setLeftIndex
-
setRightIndex
-
getLeftSsa
-
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)
-