Package io.deephaven.extensions.barrage.chunk.array

Class IntArrayExpansionKernel

java.lang.Object

io.deephaven.extensions.barrage.chunk.array.IntArrayExpansionKernel

All Implemented Interfaces:

ArrayExpansionKernel

public class IntArrayExpansionKernel
extends Object
implements ArrayExpansionKernel

Field Summary

Fields

Modifier and Type	Field	Description
static final IntArrayExpansionKernel	INSTANCE

Constructor Summary

Constructors

Constructor	Description
IntArrayExpansionKernel()

Method Summary

Modifier and Type	Method	Description
<T, A extends Any> WritableObjectChunk<T,A>	contract(Chunk<A> source, IntChunk<ChunkPositions> perElementLengthDest, WritableChunk<A> outChunk, int outOffset, int totalRows)	This contracts the source from a pair of LongChunk and Chunk<T> and produces a Chunk<T[]>.
<T, A extends Any> WritableChunk<A>	expand(ObjectChunk<T,A> source, WritableIntChunk<ChunkPositions> perElementLengthDest)	This expands the source from a T[] per element to a flat T per element.

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final IntArrayExpansionKernel INSTANCE

Constructor Details

IntArrayExpansionKernel

public IntArrayExpansionKernel()

Method Details

expand

public <T,
A extends Any> WritableChunk<A> expand(ObjectChunk<T,A> source,
 WritableIntChunk<ChunkPositions> perElementLengthDest)

Description copied from interface: ArrayExpansionKernel

This expands the source from a T[] per element to a flat T per element. The kernel records the number of consecutive elements that belong to a row in perElementLengthDest. The returned chunk is owned by the caller.

Specified by:

expand in interface ArrayExpansionKernel

Parameters:

source - the source chunk of T[] to expand

perElementLengthDest - the destination IntChunk for which dest.get(i + 1) - dest.get(i) is equivalent to source.get(i).length

Returns:

an unrolled/flattened chunk of T

contract

public <T,
A extends Any> WritableObjectChunk<T,A> contract(Chunk<A> source,
 IntChunk<ChunkPositions> perElementLengthDest,
 WritableChunk<A> outChunk,
 int outOffset,
 int totalRows)

Description copied from interface: ArrayExpansionKernel

This contracts the source from a pair of LongChunk and Chunk<T> and produces a Chunk<T[]>. The returned chunk is owned by the caller.

Specified by:

contract in interface ArrayExpansionKernel

Parameters:

source - the source chunk of T to contract

perElementLengthDest - the source IntChunk for which dest.get(i + 1) - dest.get(i) is equivalent to source.get(i).length

outChunk - the returned chunk from an earlier record batch

outOffset - the offset to start writing into outChunk

totalRows - the total known rows for this column; if known (else 0)

Returns:

a result chunk of T[]