Package com.illumon.iris.db.v2.utils.compact

Class ObjectCompactKernel

java.lang.Object

com.illumon.iris.db.v2.utils.compact.ObjectCompactKernel

All Implemented Interfaces:

CompactKernel

public class ObjectCompactKernel
extends Object
implements CompactKernel

Method Summary

Modifier and Type	Method	Description
void	compact(WritableChunk<? extends Attributes.Any> values, BooleanChunk<Attributes.Any> retainValues)	Compacts values into the front of the chunk, retaining only values where the parallel retainValues chunk has a true value.
static <T> void	compact(WritableObjectChunk<T,? extends Attributes.Any> values, BooleanChunk<Attributes.Any> retainValues)	Compact the values in values by retaining only the positions where retainValues is true.
void	compactAndCount(WritableChunk<? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, boolean countNull)	Sort valuesChunk, eliminate duplicates, and write the number of times a value occurred into the parallel slot within counts.
void	compactAndCount(WritableChunk<? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, IntChunk<Attributes.ChunkPositions> startPositions, WritableIntChunk<Attributes.ChunkLengths> lengths, boolean countNull)	For each run in valuesChunk, sort it, eliminate duplicates, and write the number of times a value occurred into the parallel slot within counts.
static <T> void	compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts)
static <T> void	compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, boolean countNull)
static <T> int	compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, int start, int length, boolean countNull)
static <T> void	compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, IntChunk<Attributes.ChunkPositions> startPositions, WritableIntChunk<Attributes.ChunkLengths> lengths, boolean countNull)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.v2.utils.compact.CompactKernel

compactAndCount, compactAndCount

Method Details

compact

public static <T> void compact(WritableObjectChunk<T,? extends Attributes.Any> values, BooleanChunk<Attributes.Any> retainValues)

Compact the values in values by retaining only the positions where retainValues is true.

Parameters:

values - the input and output chunk of values

retainValues - a chunk parallel to values, a value is retained in the output iff retainedValues is true

compact

public void compact(WritableChunk<? extends Attributes.Any> values, BooleanChunk<Attributes.Any> retainValues)

Description copied from interface: CompactKernel

Compacts values into the front of the chunk, retaining only values where the parallel retainValues chunk has a true value.

Specified by:

compact in interface CompactKernel

Parameters:

values - a chunk of values, input and output

retainValues - the values to retain

compactAndCount

public void compactAndCount(WritableChunk<? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, boolean countNull)

Description copied from interface: CompactKernel

Sort valuesChunk, eliminate duplicates, and write the number of times a value occurred into the parallel slot within counts.

Specified by:

compactAndCount in interface CompactKernel

Parameters:

valueChunk - a chunk of values, input and output

counts - an output chunk parallel to valueChunk with the number of times a value occurred

countNull - if the compaction should count nulls or not

compactAndCount

public void compactAndCount(WritableChunk<? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, IntChunk<Attributes.ChunkPositions> startPositions, WritableIntChunk<Attributes.ChunkLengths> lengths, boolean countNull)

Description copied from interface: CompactKernel

For each run in valuesChunk, sort it, eliminate duplicates, and write the number of times a value occurred into the parallel slot within counts.

Specified by:

compactAndCount in interface CompactKernel

Parameters:

valueChunk - a chunk of values, input and output

counts - an output chunk parallel to valueChunk with the number of times a value occurred

startPositions - the start of each run

lengths - the length of each run, input and output

countNull - if the compaction should count nulls or not

compactAndCount

public static <T> void compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts)

compactAndCount

public static <T> void compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, boolean countNull)

compactAndCount

public static <T> void compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, IntChunk<Attributes.ChunkPositions> startPositions, WritableIntChunk<Attributes.ChunkLengths> lengths, boolean countNull)

compactAndCount

public static <T> int compactAndCount(WritableObjectChunk<T,? extends Attributes.Values> valueChunk, WritableIntChunk<Attributes.ChunkLengths> counts, int start, int length, boolean countNull)