Kùzu C++ API
Loading...
Searching...
No Matches
kuzu::storage::ColumnChunk Class Reference

#include <column_chunk.h>

Public Member Functions

 ColumnChunk (const common::LogicalType &dataType, uint64_t capacity, bool enableCompression, ResidencyState residencyState)
 
 ColumnChunk (const common::LogicalType &dataType, bool enableCompression, ColumnChunkMetadata metadata)
 
 ColumnChunk (bool enableCompression, std::unique_ptr< ColumnChunkData > data)
 
void initializeScanState (ChunkState &state) const
 
void scan (const transaction::Transaction *transaction, const ChunkState &state, common::ValueVector &nodeID, common::ValueVector &output, common::offset_t offsetInChunk, common::length_t length) const
 
template<ResidencyState SCAN_RESIDENCY_STATE>
void scanCommitted (transaction::Transaction *transaction, ChunkState &chunkState, ColumnChunk &output, common::row_idx_t startRow=0, common::row_idx_t numRows=common::INVALID_ROW_IDX) const
 
void lookup (transaction::Transaction *transaction, const ChunkState &state, common::offset_t rowInChunk, common::ValueVector &output, common::sel_t posInOutputVector) const
 
void update (const transaction::Transaction *transaction, common::offset_t offsetInChunk, const common::ValueVector &values)
 
uint64_t getEstimatedMemoryUsage () const
 
void serialize (common::Serializer &serializer) const
 
uint64_t getNumValues () const
 
void setNumValues (const uint64_t numValues) const
 
common::row_idx_t getNumUpdatedRows (const transaction::Transaction *transaction) const
 
std::pair< std::unique_ptr< ColumnChunk >, std::unique_ptr< ColumnChunk > > scanUpdates (const transaction::Transaction *transaction) const
 
void setData (std::unique_ptr< ColumnChunkData > data)
 
ColumnChunkDatagetData () const
 
const ColumnChunkDatagetConstData () const
 
std::unique_ptr< ColumnChunkDatamoveData ()
 
common::LogicalTypegetDataType ()
 
const common::LogicalTypegetDataType () const
 
bool isCompressionEnabled () const
 
ResidencyState getResidencyState () const
 
bool hasUpdates () const
 
bool hasUpdates (const transaction::Transaction *transaction, common::row_idx_t startRow, common::length_t numRows) const
 
void resetToEmpty () const
 
void resetToAllNull () const
 
void resize (uint64_t newSize) const
 
void resetUpdateInfo ()
 

Static Public Member Functions

static std::unique_ptr< ColumnChunkdeserialize (common::Deserializer &deSer)
 

Constructor & Destructor Documentation

◆ ColumnChunk() [1/3]

kuzu::storage::ColumnChunk::ColumnChunk ( const common::LogicalType & dataType,
uint64_t capacity,
bool enableCompression,
ResidencyState residencyState )

◆ ColumnChunk() [2/3]

kuzu::storage::ColumnChunk::ColumnChunk ( const common::LogicalType & dataType,
bool enableCompression,
ColumnChunkMetadata metadata )

◆ ColumnChunk() [3/3]

kuzu::storage::ColumnChunk::ColumnChunk ( bool enableCompression,
std::unique_ptr< ColumnChunkData > data )

Member Function Documentation

◆ deserialize()

static std::unique_ptr< ColumnChunk > kuzu::storage::ColumnChunk::deserialize ( common::Deserializer & deSer)
static

◆ getConstData()

const ColumnChunkData & kuzu::storage::ColumnChunk::getConstData ( ) const
inline

◆ getData()

ColumnChunkData & kuzu::storage::ColumnChunk::getData ( ) const
inline

◆ getDataType() [1/2]

common::LogicalType & kuzu::storage::ColumnChunk::getDataType ( )
inline

◆ getDataType() [2/2]

const common::LogicalType & kuzu::storage::ColumnChunk::getDataType ( ) const
inline

◆ getEstimatedMemoryUsage()

uint64_t kuzu::storage::ColumnChunk::getEstimatedMemoryUsage ( ) const
inline

◆ getNumUpdatedRows()

common::row_idx_t kuzu::storage::ColumnChunk::getNumUpdatedRows ( const transaction::Transaction * transaction) const

◆ getNumValues()

uint64_t kuzu::storage::ColumnChunk::getNumValues ( ) const
inline

◆ getResidencyState()

ResidencyState kuzu::storage::ColumnChunk::getResidencyState ( ) const
inline

◆ hasUpdates() [1/2]

bool kuzu::storage::ColumnChunk::hasUpdates ( ) const
inline

◆ hasUpdates() [2/2]

bool kuzu::storage::ColumnChunk::hasUpdates ( const transaction::Transaction * transaction,
common::row_idx_t startRow,
common::length_t numRows ) const

◆ initializeScanState()

void kuzu::storage::ColumnChunk::initializeScanState ( ChunkState & state) const

◆ isCompressionEnabled()

bool kuzu::storage::ColumnChunk::isCompressionEnabled ( ) const
inline

◆ lookup()

void kuzu::storage::ColumnChunk::lookup ( transaction::Transaction * transaction,
const ChunkState & state,
common::offset_t rowInChunk,
common::ValueVector & output,
common::sel_t posInOutputVector ) const

◆ moveData()

std::unique_ptr< ColumnChunkData > kuzu::storage::ColumnChunk::moveData ( )
inline

◆ resetToAllNull()

void kuzu::storage::ColumnChunk::resetToAllNull ( ) const
inline

◆ resetToEmpty()

void kuzu::storage::ColumnChunk::resetToEmpty ( ) const
inline

◆ resetUpdateInfo()

void kuzu::storage::ColumnChunk::resetUpdateInfo ( )
inline

◆ resize()

void kuzu::storage::ColumnChunk::resize ( uint64_t newSize) const
inline

◆ scan()

void kuzu::storage::ColumnChunk::scan ( const transaction::Transaction * transaction,
const ChunkState & state,
common::ValueVector & nodeID,
common::ValueVector & output,
common::offset_t offsetInChunk,
common::length_t length ) const

◆ scanCommitted()

template<ResidencyState SCAN_RESIDENCY_STATE>
void kuzu::storage::ColumnChunk::scanCommitted ( transaction::Transaction * transaction,
ChunkState & chunkState,
ColumnChunk & output,
common::row_idx_t startRow = 0,
common::row_idx_t numRows = common::INVALID_ROW_IDX ) const

◆ scanUpdates()

std::pair< std::unique_ptr< ColumnChunk >, std::unique_ptr< ColumnChunk > > kuzu::storage::ColumnChunk::scanUpdates ( const transaction::Transaction * transaction) const

◆ serialize()

void kuzu::storage::ColumnChunk::serialize ( common::Serializer & serializer) const

◆ setData()

void kuzu::storage::ColumnChunk::setData ( std::unique_ptr< ColumnChunkData > data)
inline

◆ setNumValues()

void kuzu::storage::ColumnChunk::setNumValues ( const uint64_t numValues) const
inline

◆ update()

void kuzu::storage::ColumnChunk::update ( const transaction::Transaction * transaction,
common::offset_t offsetInChunk,
const common::ValueVector & values )

The documentation for this class was generated from the following file: