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

Class ByteArrayExpansionKernel

java.lang.Object

io.deephaven.extensions.barrage.chunk.array.ByteArrayExpansionKernel

All Implemented Interfaces:

ArrayExpansionKernel

public class ByteArrayExpansionKernel
extends Object
implements ArrayExpansionKernel

Field Summary

Fields

Modifier and Type	Field	Description
static final ByteArrayExpansionKernel	INSTANCE

Constructor Summary

Constructors

Constructor	Description
ByteArrayExpansionKernel()

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 ByteArrayExpansionKernel INSTANCE

Constructor Details

ByteArrayExpansionKernel

public ByteArrayExpansionKernel()

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[]