Package io.deephaven.engine.table.impl.by.ssmcountdistinct

Class SsmUniqueRollupContext

java.lang.Object

io.deephaven.engine.table.impl.by.ssmcountdistinct.SsmUniqueRollupContext

All Implemented Interfaces:

IterativeChunkedAggregationOperator.BucketedContext, IterativeChunkedAggregationOperator.SingletonContext, SafeCloseable, AutoCloseable

public class SsmUniqueRollupContext
extends Object
implements IterativeChunkedAggregationOperator.BucketedContext, IterativeChunkedAggregationOperator.SingletonContext

Scratch context for the rollup "unique" operator. Per destination it gathers the unique constituent values to add to (or remove from) that destination's multiset into values, then compacts them (into distinct values + counts) so they can be inserted into or removed from the SSM in a single bulk call rather than one constituent at a time. A modify gathers its removals into values/counts and its additions into postValues/postCounts, then nets the two so values unchanged across the modify cancel out before touching the SSM (removedSize/addedSize carry the surviving lengths).

Field Summary

Fields

Modifier and Type	Field	Description
final MutableInt	addedSize
final WritableIntChunk<ChunkLengths>	counts
final WritableIntChunk<ChunkLengths>	postCounts
final WritableChunk<Values>	postValues
final SegmentedSortedMultiSet.RemoveContext	removeContext
final MutableInt	removedSize
final WritableChunk<Values>	values

Constructor Summary

Constructors

Constructor	Description
SsmUniqueRollupContext(ChunkType chunkType, int size)

Method Summary

Modifier and Type	Method	Description
void	close()

Methods inherited from class java.lang.Object

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

Field Details

removeContext

public final SegmentedSortedMultiSet.RemoveContext removeContext

values

public final WritableChunk<Values> values

counts

public final WritableIntChunk<ChunkLengths> counts

postValues

public final WritableChunk<Values> postValues

postCounts

public final WritableIntChunk<ChunkLengths> postCounts

removedSize

public final MutableInt removedSize

addedSize

public final MutableInt addedSize

Constructor Details

SsmUniqueRollupContext

public SsmUniqueRollupContext(ChunkType chunkType,
 int size)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable