Package io.deephaven.barrage.chunk.vector

Class DoubleVectorExpansionKernel

java.lang.Object

io.deephaven.barrage.chunk.vector.DoubleVectorExpansionKernel

All Implemented Interfaces:

VectorExpansionKernel

public class DoubleVectorExpansionKernel
extends Object
implements VectorExpansionKernel

Field Summary

Fields

Modifier and Type	Field	Description
static final DoubleVectorExpansionKernel	INSTANCE

Constructor Summary

Constructors

Constructor	Description
DoubleVectorExpansionKernel()

Method Summary

Modifier and Type	Method	Description
<A extends Attributes.Any> WritableObjectChunk<DbArrayBase,A>	contract(Chunk<A> source, IntChunk<Attributes.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[]>.
<A extends Attributes.Any> WritableChunk<A>	expand(ObjectChunk<DbArrayBase,A> source, WritableIntChunk<Attributes.ChunkPositions> perElementLengthDest)	This expands the source from a TVector 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 DoubleVectorExpansionKernel INSTANCE

Constructor Details

DoubleVectorExpansionKernel

public DoubleVectorExpansionKernel()

Method Details

expand

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

Description copied from interface: VectorExpansionKernel

This expands the source from a TVector 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 VectorExpansionKernel

Parameters:

source - the source chunk of TVector 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 <A extends Attributes.Any>
WritableObjectChunk<DbArrayBase,A> contract(Chunk<A> source,
 IntChunk<Attributes.ChunkPositions> perElementLengthDest,
 WritableChunk<A> outChunk,
 int outOffset,
 int totalRows)

Description copied from interface: VectorExpansionKernel

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 VectorExpansionKernel

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