Package com.activeviam.column

Class LazyChunkedCompositeColumn<K>

java.lang.Object

com.qfs.column.impl.AChunkedColumn<K,IChunk<K>>

com.activeviam.column.impl.ChunkedColumn<K>

com.activeviam.column.impl.LazyChunkedColumn<K>

com.activeviam.column.LazyChunkedColumnWithAggregation<K>

com.activeviam.column.LazyChunkedCompositeColumn<K>

All Implemented Interfaces:

IArray, IArrayReader, IArrayWriter, IDecoratedArray<Object,K>, IVectorArrayWriter, IWritableArray, IColumn<K>, ICompositeColumn, ICompositeReadableColumn, IMemoryMonitored, Externalizable, Serializable

public class LazyChunkedCompositeColumn<K>
extends LazyChunkedColumnWithAggregation<K>
implements ICompositeColumn

A composite column with chunks.

Author:

ActiveViam

See Also:

• Serialized Form

Field Summary

Fields inherited from class com.activeviam.column.impl.LazyChunkedColumn

DEFAULT_CHUNK_SIZE

Constructor Summary

Constructors

Constructor	Description
LazyChunkedCompositeColumn()	Empty constructor for serialization.
LazyChunkedCompositeColumn(IUserDefinedAggregation aggregation, int chunkSize, boolean isTransient, IAllocationSettings allocationSettings)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	copy(int row, IArrayReader value)	Copies the values of the array in the specified rows.
IArrayCursor	createArrayCursor()	Creates a new read-only cursor that can be moved up and down the array.
ICompositeColumnCursor	createCursor()	Creates a new cursor on this column.
IChunkComposite	getChunk(int row)	Gets the chunk containing the given row.
boolean	isNull(int row)	Gets whether null is stored in a given row at a given position.
K	read(int row)	Reads a value at some index in an array.
boolean	readBoolean(int row)	Reads a boolean primitive value from the array.
double	readDouble(int row)	Reads a double primitive value from the array.
void	readExternal(ObjectInput in)
float	readFloat(int row)	Reads a float primitive value from the array.
int	readInt(int row)	Reads an int primitive value from the array.
long	readLong(int row)	Reads a long primitive value from the array.
void	writeExternal(ObjectOutput out)

Methods inherited from class com.activeviam.column.LazyChunkedColumnWithAggregation

getAggregation

Methods inherited from class com.activeviam.column.impl.ChunkedColumn

getAllocationSettings, getDecoratedValue, isTransient, setDecoratedValue

Methods inherited from class com.qfs.column.impl.AChunkedColumn

addDouble, addFloat, addInt, addLong, chunkId, chunkPosition, destroy, ensureCapacity, getCapacity, getChunkCount, getChunkSize, getMemoryStatistic, getMemoryStatisticWithLimit, getWeight, growCapacity, write, writeBoolean, writeDouble, writeFloat, writeInt, writeLong

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.qfs.chunk.IArrayReader

readVector

Methods inherited from interface com.qfs.chunk.IArrayWriter

addDouble, addFloat, addInt, addLong, write, writeBoolean, writeDouble, writeFloat, writeInt, writeLong

Constructor Details

LazyChunkedCompositeColumn

public LazyChunkedCompositeColumn()

Empty constructor for serialization.

LazyChunkedCompositeColumn

public LazyChunkedCompositeColumn(IUserDefinedAggregation aggregation,
 int chunkSize,
 boolean isTransient,
 IAllocationSettings allocationSettings)

Constructor.

Parameters:

aggregation - the aggregation that this column stores aggregates for

chunkSize - the size of the underlying chunks

isTransient - true if the data stored in this column is transient (short lived), false otherwise

allocationSettings - additional info for allocating the chunks

Method Details

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class LazyChunkedColumnWithAggregation<K>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class LazyChunkedColumnWithAggregation<K>

Throws:

IOException

ClassNotFoundException

read

public K read(int row)

Description copied from interface: IArrayReader

Reads a value at some index in an array.

Specified by:

read in interface IArrayReader

Specified by:

read in interface IColumn<K>

Overrides:

read in class AChunkedColumn<K,IChunk<K>>

Parameters:

row - 0-based index in an array

Returns:

the data stored at that position in the array

readInt

public int readInt(int row)

Description copied from interface: IArrayReader

Reads an int primitive value from the array.

An exception is thrown if the value is not of the right type.

Specified by:

readInt in interface IArrayReader

Overrides:

readInt in class AChunkedColumn<K,IChunk<K>>

Parameters:

row - 0-based index in an array

Returns:

int value

readLong

public long readLong(int row)

Description copied from interface: IArrayReader

Reads a long primitive value from the array.

An exception is thrown if the value is not of the right type.

Specified by:

readLong in interface IArrayReader

Overrides:

readLong in class AChunkedColumn<K,IChunk<K>>

Parameters:

row - 0-based index in an array

Returns:

long value

readFloat

public float readFloat(int row)

Description copied from interface: IArrayReader

Reads a float primitive value from the array.

An exception is thrown if the value is not of the right type.

Specified by:

readFloat in interface IArrayReader

Overrides:

readFloat in class AChunkedColumn<K,IChunk<K>>

Parameters:

row - 0-based index in an array

Returns:

float value

readDouble

public double readDouble(int row)

Description copied from interface: IArrayReader

Reads a double primitive value from the array.

An exception is thrown if the value is not of the right type.

Specified by:

readDouble in interface IArrayReader

Overrides:

readDouble in class AChunkedColumn<K,IChunk<K>>

Parameters:

row - 0-based index in an array

Returns:

double value

readBoolean

public boolean readBoolean(int row)

Description copied from interface: IArrayReader

Reads a boolean primitive value from the array.

An exception is thrown if the value is not of the right type.

Specified by:

readBoolean in interface IArrayReader

Overrides:

readBoolean in class AChunkedColumn<K,IChunk<K>>

Parameters:

row - 0-based index in an array

Returns:

boolean value

isNull

public boolean isNull(int row)

Description copied from interface: IArrayReader

Gets whether null is stored in a given row at a given position.

Specified by:

isNull in interface IArrayReader

Overrides:

isNull in class AChunkedColumn<K,IChunk<K>>

Parameters:

row - 0-based index in an array

Returns:

true if the element stored at that position is null, false otherwise

createCursor

public ICompositeColumnCursor createCursor()

Description copied from interface: ICompositeReadableColumn

Creates a new cursor on this column.

Specified by:

createCursor in interface ICompositeColumn

Specified by:

createCursor in interface ICompositeReadableColumn

Returns:

a new cursor on this column

getChunk

public IChunkComposite getChunk(int row)

Description copied from interface: ICompositeColumn

Gets the chunk containing the given row.

Specified by:

getChunk in interface ICompositeColumn

Parameters:

row - a row

Returns:

the chunk containing the row

copy

public void copy(int row,
 IArrayReader value)

Description copied from interface: ICompositeColumn

Copies the values of the array in the specified rows.

Specified by:

copy in interface ICompositeColumn

Parameters:

row - the position where to copy the values

value - the object containing the values to copy

createArrayCursor

public IArrayCursor createArrayCursor()

Description copied from interface: IArray

Creates a new read-only cursor that can be moved up and down the array. This cursor delegates all reading calls to the underlying array.

Specified by:

createArrayCursor in interface IArray

Specified by:

createArrayCursor in interface IWritableArray

Overrides:

createArrayCursor in class ChunkedColumn<K>

Returns:

the cursor, stationed at index 0 of the array