|
| InternalIDColumn (std::string name, BMFileHandle *dataFH, BufferManager *bufferManager, ShadowFile *shadowFile, bool enableCompression) |
|
void | scan (transaction::Transaction *transaction, const ChunkState &state, common::offset_t startOffsetInChunk, common::row_idx_t numValuesToScan, common::ValueVector *nodeIDVector, common::ValueVector *resultVector) override |
|
void | scan (transaction::Transaction *transaction, const ChunkState &state, common::offset_t startOffsetInGroup, common::offset_t endOffsetInGroup, common::ValueVector *resultVector, uint64_t offsetInVector) override |
|
void | lookupInternal (transaction::Transaction *transaction, const ChunkState &state, common::offset_t nodeOffset, common::ValueVector *resultVector, uint32_t posInVector) override |
|
common::table_id_t | getCommonTableID () const |
|
void | setCommonTableID (common::table_id_t tableID) |
|
Public Member Functions inherited from kuzu::storage::Column |
| Column (std::string name, common::LogicalType dataType, BMFileHandle *dataFH, BufferManager *bufferManager, ShadowFile *shadowFile, bool enableCompression, bool requireNullColumn=true) |
|
virtual | ~Column () |
|
virtual void | lookupValue (transaction::Transaction *transaction, const ChunkState &state, common::offset_t nodeOffset, common::ValueVector *resultVector, uint32_t posInVector) |
|
virtual void | scan (transaction::Transaction *transaction, const ChunkState &state, ColumnChunkData *columnChunk, common::offset_t startOffset=0, common::offset_t endOffset=common::INVALID_OFFSET) |
|
common::LogicalType & | getDataType () |
|
const common::LogicalType & | getDataType () const |
|
Column * | getNullColumn () const |
|
std::string | getName () const |
|
virtual void | scan (transaction::Transaction *transaction, const ChunkState &state, common::offset_t startOffsetInGroup, common::offset_t endOffsetInGroup, uint8_t *result) |
|
virtual void | write (ColumnChunkData &persistentChunk, ChunkState &state, common::offset_t dstOffset, ColumnChunkData *data, common::offset_t srcOffset, common::length_t numValues) |
|
common::offset_t | appendValues (ColumnChunkData &persistentChunk, ChunkState &state, const uint8_t *data, const common::NullMask *nullChunkData, common::offset_t numValues) |
|
virtual void | checkpointColumnChunk (ColumnCheckpointState &checkpointState) |
|
template<class TARGET > |
TARGET & | cast () |
|
template<class TARGET > |
const TARGET & | cast () const |
|
|
Static Public Member Functions inherited from kuzu::storage::Column |
static std::unique_ptr< ColumnChunkData > | flushChunkData (const ColumnChunkData &chunkData, BMFileHandle &dataFH) |
|
static std::unique_ptr< ColumnChunkData > | flushNonNestedChunkData (const ColumnChunkData &chunkData, BMFileHandle &dataFH) |
|
static ColumnChunkMetadata | flushData (const ColumnChunkData &chunkData, BMFileHandle &dataFH) |
|
Protected Member Functions inherited from kuzu::storage::Column |
virtual void | scanInternal (transaction::Transaction *transaction, const ChunkState &state, common::offset_t startOffsetInChunk, common::row_idx_t numValuesToScan, common::ValueVector *nodeIDVector, common::ValueVector *resultVector) |
|
void | scanUnfiltered (transaction::Transaction *transaction, PageCursor &pageCursor, uint64_t numValuesToScan, common::ValueVector *resultVector, const ColumnChunkMetadata &chunkMeta, uint64_t startPosInVector=0) const |
|
void | scanFiltered (transaction::Transaction *transaction, PageCursor &pageCursor, uint64_t numValuesToScan, const common::SelectionVector &selVector, common::ValueVector *resultVector, const ColumnChunkMetadata &chunkMeta) const |
|
void | readFromPage (transaction::Transaction *transaction, common::page_idx_t pageIdx, const std::function< void(uint8_t *)> &func) const |
|
virtual void | writeValues (ColumnChunkData &persistentChunk, ChunkState &state, common::offset_t dstOffset, const uint8_t *data, const common::NullMask *nullChunkData, common::offset_t srcOffset=0, common::offset_t numValues=1) |
|
void | updatePageWithCursor (PageCursor cursor, const std::function< void(uint8_t *, common::offset_t)> &writeOp) const |
|
void | updateStatistics (ColumnChunkMetadata &metadata, common::offset_t maxIndex, const std::optional< StorageValue > &min, const std::optional< StorageValue > &max) const |
|
bool | isMaxOffsetOutOfPagesCapacity (const ColumnChunkMetadata &metadata, common::offset_t maxOffset) const |
|
virtual bool | canCheckpointInPlace (const ChunkState &state, const ColumnCheckpointState &checkpointState) |
|
virtual void | checkpointColumnChunkInPlace (ChunkState &state, const ColumnCheckpointState &checkpointState) |
|
void | checkpointNullData (const ColumnCheckpointState &checkpointState) const |
|
virtual void | checkpointColumnChunkOutOfPlace (ChunkState &state, const ColumnCheckpointState &checkpointState) |
|
Static Protected Member Functions inherited from kuzu::storage::Column |
static PageCursor | getPageCursorForOffsetInGroup (common::offset_t offsetInChunk, const ChunkState &state) |
|
static bool | isInRange (uint64_t val, uint64_t start, uint64_t end) |
|
Protected Attributes inherited from kuzu::storage::Column |
std::string | name |
|
DBFileID | dbFileID |
|
common::LogicalType | dataType |
|
BMFileHandle * | dataFH |
|
BufferManager * | bufferManager |
|
ShadowFile * | shadowFile |
|
std::unique_ptr< NullColumn > | nullColumn |
|
read_values_to_vector_func_t | readToVectorFunc |
|
write_values_from_vector_func_t | writeFromVectorFunc |
|
write_values_func_t | writeFunc |
|
read_values_to_page_func_t | readToPageFunc |
|
batch_lookup_func_t | batchLookupFunc |
|
bool | enableCompression |
|