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 byteENTRY_LEFT_IS_BUILDERstatic byteENTRY_LEFT_IS_EMPTYstatic byteENTRY_LEFT_IS_INDEXstatic byteENTRY_LEFT_IS_SSAstatic byteENTRY_LEFT_MASKstatic byteENTRY_RIGHT_IS_BUILDERstatic byteENTRY_RIGHT_IS_EMPTYstatic byteENTRY_RIGHT_IS_INDEXstatic byteENTRY_RIGHT_IS_SSAstatic byteENTRY_RIGHT_MASK -
Method Summary
Modifier and Type Method Description intbuildAdditions(boolean isLeftSide, Index additions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)voiddoRehash(com.illumon.iris.db.v2.RightIncrementalChunkedAsOfJoinStateManager.BuildContext bc, LongArraySource addedSlots)intgatherModifications(Index restampAdditions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)intgatherShiftIndex(Index restampAdditions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)IndexgetLeftIndex(long slot)SegmentedSortedArraygetLeftSsa(long slot)SegmentedSortedArraygetLeftSsa(long slot, Function<Index,SegmentedSortedArray> ssaFactory)SegmentedSortedArraygetLeftSsaOrIndex(long slot, org.apache.commons.lang3.mutable.MutableObject<Index> indexOutput)intgetOverflowSize()IndexgetRightIndex(long slot)SegmentedSortedArraygetRightSsa(long slot)SegmentedSortedArraygetRightSsa(long slot, Function<Index,SegmentedSortedArray> ssaFactory)SegmentedSortedArraygetRightSsaOrIndex(long slot, org.apache.commons.lang3.mutable.MutableObject<Index> indexOutput)bytegetState(long slot)intgetTableSize()intmarkForRemoval(Index restampRemovals, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)intprobeAdditions(Index restampAdditions, ColumnSource<?>[] sources, LongArraySource slots, ObjectArraySource<Index.SequentialBuilder> sequentialBuilders)booleanrehashRequired()voidsetLeftIndex(long slot, Index index)voidsetMaximumLoadFactor(double maximumLoadFactor)voidsetRightIndex(long slot, Index index)voidsetTargetLoadFactor(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)
-