#include <column_chunk.h>
|
| 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) |
|
ColumnChunkData & | getData () const |
|
const ColumnChunkData & | getConstData () const |
|
std::unique_ptr< ColumnChunkData > | moveData () |
|
common::LogicalType & | getDataType () |
|
const common::LogicalType & | getDataType () 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 () |
|
◆ ColumnChunk() [1/3]
◆ ColumnChunk() [2/3]
◆ ColumnChunk() [3/3]
kuzu::storage::ColumnChunk::ColumnChunk |
( |
bool | enableCompression, |
|
|
std::unique_ptr< ColumnChunkData > | data ) |
◆ deserialize()
◆ getConstData()
◆ getData()
◆ getDataType() [1/2]
◆ getDataType() [2/2]
◆ getEstimatedMemoryUsage()
uint64_t kuzu::storage::ColumnChunk::getEstimatedMemoryUsage |
( |
| ) |
const |
|
inline |
◆ getNumUpdatedRows()
◆ 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]
◆ initializeScanState()
void kuzu::storage::ColumnChunk::initializeScanState |
( |
ChunkState & | state | ) |
const |
◆ isCompressionEnabled()
bool kuzu::storage::ColumnChunk::isCompressionEnabled |
( |
| ) |
const |
|
inline |
◆ lookup()
◆ 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()
◆ scanCommitted()
◆ scanUpdates()
◆ serialize()
◆ 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()
The documentation for this class was generated from the following file: