Inheritance diagram for duckdb::ColumnData:

Collaboration diagram for duckdb::ColumnData:

[legend]

Public Member Functions
	ColumnData (BlockManager &block_manager, DataTableInfo &info, idx_t column_index, LogicalType type, ColumnDataType data_type, optional_ptr< ColumnData > parent)

virtual FilterPropagateResult	CheckZonemap (ColumnScanState &state, TableFilter &filter)

BlockManager &	GetBlockManager () const

DatabaseInstance &	GetDatabase () const

DataTableInfo &	GetTableInfo () const

StorageManager &	GetStorageManager () const

virtual idx_t	GetMaxEntry ()

idx_t	GetAllocationSize () const

optional_ptr< const CompressionFunction >	GetCompressionFunction () const

virtual void	SetDataType (ColumnDataType data_type)

ColumnDataType	GetDataType () const

bool	HasParent () const

void	SetParent (optional_ptr< ColumnData > parent)

const ColumnData &	Parent () const

virtual const BaseStatistics &	GetChildStats (const ColumnData &child) const

const LogicalType &	GetType () const

ColumnSegmentTree &	GetSegmentTree ()

void	SetCount (idx_t new_count)

bool	HasUpdates () const
	Whether or not the column has any updates.

bool	HasChanges (idx_t start_row, idx_t end_row) const

bool	HasChanges () const
	Whether or not the column has changes at this level.

virtual bool	HasAnyChanges () const
	Whether or not the column has ANY changes, including in child columns.

virtual ScanVectorType	GetVectorScanType (ColumnScanState &state, idx_t scan_count, Vector &result)
	Whether or not we can scan an entire vector.

virtual void	InitializePrefetch (PrefetchState &prefetch_state, ColumnScanState &scan_state, idx_t rows)
	Initialize prefetch state with required I/O data for the next N rows.

virtual void	InitializeScan (ColumnScanState &state)
	Initialize a scan of the column.

virtual void	InitializeScanWithOffset (ColumnScanState &state, idx_t row_idx)
	Initialize a scan starting at the specified offset.

idx_t	Scan (TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result)
	Scan the next vector from the column.

virtual idx_t	Scan (TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, idx_t scan_count)

virtual void	ScanCommittedRange (idx_t row_group_start, idx_t offset_in_row_group, idx_t count, Vector &result)

virtual idx_t	ScanCount (ColumnScanState &state, Vector &result, idx_t count, idx_t result_offset=0)

virtual void	Filter (TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, SelectionVector &sel, idx_t &count, const TableFilter &filter, TableFilterState &filter_state)
	Select.

virtual void	Select (TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, SelectionVector &sel, idx_t count)

virtual void	Skip (ColumnScanState &state, idx_t count=STANDARD_VECTOR_SIZE)
	Skip the scan forward by "count" rows.

virtual void	InitializeAppend (ColumnAppendState &state)
	Initialize an appending phase for this column.

virtual void	Append (BaseStatistics &stats, ColumnAppendState &state, Vector &vector, idx_t count)
	Append a vector of type [type] to the end of the column.

void	Append (ColumnAppendState &state, Vector &vector, idx_t count)
	Append a vector of type [type] to the end of the column.

virtual void	AppendData (BaseStatistics &stats, ColumnAppendState &state, UnifiedVectorFormat &vdata, idx_t count)

virtual void	RevertAppend (row_t new_count)
	Revert a set of appends to the ColumnData.

virtual idx_t	Fetch (ColumnScanState &state, row_t row_id, Vector &result)
	Fetch the vector from the column data that belongs to this specific row.

virtual void	FetchRow (TransactionData transaction, ColumnFetchState &state, const StorageIndex &storage_index, row_t row_id, Vector &result, idx_t result_idx)
	Fetch a specific row id and append it to the vector.

virtual void	Update (TransactionData transaction, DataTable &data_table, idx_t column_index, Vector &update_vector, row_t *row_ids, idx_t update_count, idx_t row_group_start)

virtual void	UpdateColumn (TransactionData transaction, DataTable &data_table, const vector< column_t > &column_path, Vector &update_vector, row_t *row_ids, idx_t update_count, idx_t depth, idx_t row_group_start)

virtual unique_ptr< BaseStatistics >	GetUpdateStatistics ()

virtual void	VisitBlockIds (BlockIdVisitor &visitor) const

virtual unique_ptr< ColumnCheckpointState >	CreateCheckpointState (const RowGroup &row_group, PartialBlockManager &partial_block_manager)

unique_ptr< ColumnCheckpointState >	Checkpoint (const RowGroup &row_group, ColumnCheckpointInfo &info)

virtual unique_ptr< ColumnCheckpointState >	Checkpoint (const RowGroup &row_group, ColumnCheckpointInfo &info, const BaseStatistics &stats)

virtual void	CheckpointScan (ColumnSegment &segment, ColumnScanState &state, idx_t count, Vector &scan_vector) const

virtual bool	IsPersistent ()

vector< DataPointer >	GetDataPointers ()

virtual PersistentColumnData	Serialize ()

void	InitializeColumn (PersistentColumnData &column_data)

virtual void	InitializeColumn (PersistentColumnData &column_data, BaseStatistics &target_stats)

virtual void	GetColumnSegmentInfo (const QueryContext &context, idx_t row_group_index, vector< idx_t > col_path, vector< ColumnSegmentInfo > &result)

virtual void	Verify (RowGroup &parent)

FilterPropagateResult	CheckZonemap (const StorageIndex &index, TableFilter &filter)

void	MergeStatistics (const BaseStatistics &other)

void	MergeIntoStatistics (BaseStatistics &other)

unique_ptr< BaseStatistics >	GetStatistics () const

const BaseStatistics &	GetStatisticsRef () const

template<class TARGET >
TARGET &	Cast ()

template<class TARGET >
const TARGET &	Cast () const

Public Member Functions inherited from duckdb::enable_shared_from_this< ColumnData >
shared_ptr< ColumnData >	shared_from_this ()

shared_ptr< ColumnData const >	shared_from_this () const

Static Public Member Functions
static shared_ptr< ColumnData >	Deserialize (BlockManager &block_manager, DataTableInfo &info, idx_t column_index, ReadStream &source, const LogicalType &type)

static shared_ptr< ColumnData >	CreateColumn (BlockManager &block_manager, DataTableInfo &info, idx_t column_index, const LogicalType &type, ColumnDataType data_type=ColumnDataType::MAIN_TABLE, optional_ptr< ColumnData > parent=nullptr)

Public Attributes
atomic< idx_t >	count
	The count of the column data.

BlockManager &	block_manager
	The block manager.

DataTableInfo &	info
	Table info for the column.

idx_t	column_index
	The column index of the column, either within the parent table or within the parent.

LogicalType	type
	The type of the column.

Protected Member Functions
void	AppendTransientSegment (SegmentLock &l, idx_t start_row)
	Append a transient segment.

void	AppendSegment (SegmentLock &l, unique_ptr< ColumnSegment > segment)

void	BeginScanVectorInternal (ColumnScanState &state)

idx_t	ScanVector (ColumnScanState &state, Vector &result, idx_t remaining, ScanVectorType scan_type, idx_t result_offset=0)
	Scans a base vector from the column.

idx_t	ScanVector (TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, idx_t target_scan, ScanVectorType scan_type, UpdateScanType update_type)
	Scans a vector from the column merged with any potential updates.

idx_t	ScanVector (TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, idx_t target_scan, UpdateScanType update_type)

void	SelectVector (ColumnScanState &state, Vector &result, idx_t target_count, const SelectionVector &sel, idx_t sel_count)

void	FilterVector (ColumnScanState &state, Vector &result, idx_t target_count, SelectionVector &sel, idx_t &sel_count, const TableFilter &filter, TableFilterState &filter_state)

void	FetchUpdates (TransactionData transaction, idx_t vector_index, Vector &result, idx_t scan_count, UpdateScanType update_type)

void	FetchUpdateRow (TransactionData transaction, row_t row_id, Vector &result, idx_t result_idx)

void	UpdateInternal (TransactionData transaction, DataTable &data_table, idx_t column_index, Vector &update_vector, row_t *row_ids, idx_t update_count, Vector &base_vector, idx_t row_group_start)

idx_t	FetchUpdateData (ColumnScanState &state, row_t *row_ids, Vector &base_vector, idx_t row_group_start)

idx_t	GetVectorCount (idx_t vector_index) const

Protected Member Functions inherited from duckdb::enable_shared_from_this< ColumnData >
	enable_shared_from_this (enable_shared_from_this const &) noexcept

enable_shared_from_this &	operator= (enable_shared_from_this const &) noexcept

Protected Attributes
ColumnSegmentTree	data
	The segments holding the data of this column segment.

mutex	update_lock
	The lock for the updates.

unique_ptr< UpdateSegment >	updates
	The updates for this column segment.

mutex	stats_lock
	The lock for the stats.

atomic< idx_t >	allocation_size
	Total transient allocation size.

unique_ptr< SegmentStatistics >	stats
	The stats of the root segment.

Private Member Functions
void	UpdateCompressionFunction (SegmentLock &l, const CompressionFunction &function)

Private Attributes
atomic< ColumnDataType >	data_type
	Whether or not this column data belongs to a main table or if it is transaction local.

optional_ptr< ColumnData >	parent
	The parent column (if any)

atomic_ptr< const CompressionFunction >	compression

Friends
class	ColumnDataCheckpointer

Member Function Documentation

◆ GetBlockManager()

BlockManager & duckdb::ColumnData::GetBlockManager ( ) const

inline

                                          {
        return block_manager;
    }

◆ GetAllocationSize()

idx_t duckdb::ColumnData::GetAllocationSize ( ) const

inline

                                    {
        return allocation_size;
    }

◆ GetCompressionFunction()

optional_ptr< const CompressionFunction > duckdb::ColumnData::GetCompressionFunction ( ) const

inline

                                                                           {
        return compression.get();
    }

◆ GetDataType()

ColumnDataType duckdb::ColumnData::GetDataType ( ) const

inline

                                       {
        return data_type;
    }

◆ HasParent()

bool duckdb::ColumnData::HasParent ( ) const

inline

                           {
        return parent;
    }

◆ SetParent()

void duckdb::ColumnData::SetParent ( optional_ptr< ColumnData > parent )

inline

                                                    {
        this->parent = parent;
    }

◆ Parent()

const ColumnData & duckdb::ColumnData::Parent ( ) const

inline

                                     {
        D_ASSERT(HasParent());
        return *parent;
    }

◆ GetType()

const LogicalType & duckdb::ColumnData::GetType ( ) const

inline

                                       {
        return type;
    }

◆ GetSegmentTree()

ColumnSegmentTree & duckdb::ColumnData::GetSegmentTree ( )

inline

                                        {
        return data;
    }

◆ SetCount()

void duckdb::ColumnData::SetCount ( idx_t new_count )

inline

                                   {
        this->count = new_count;
    }

◆ Checkpoint()

unique_ptr< ColumnCheckpointState > duckdb::ColumnData::Checkpoint	(	const RowGroup &	row_group,
		ColumnCheckpointInfo &	info
	)

If this is a nested column, "stats" are the corresponding statistics from the parent column Otherwise, "stats" == this->statistics->stats

◆ Cast() [1/2]

template<class TARGET >

TARGET & duckdb::ColumnData::Cast ( )

inline

                   {
        DynamicCastCheck<TARGET>(this);
        return reinterpret_cast<TARGET &>(*this);
    }

◆ Cast() [2/2]

template<class TARGET >

const TARGET & duckdb::ColumnData::Cast ( ) const

inline

                               {
        DynamicCastCheck<TARGET>(this);
        return reinterpret_cast<const TARGET &>(*this);
    }

Member Data Documentation

◆ compression

atomic_ptr<const CompressionFunction> duckdb::ColumnData::compression

private

The compression function used by the ColumnData This is empty if the segments have mixed compression or the ColumnData is empty

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

external/duckdb/duckdb.hpp

Public Member Functions

Static Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Friends

Member Function Documentation

◆ GetBlockManager()

◆ GetAllocationSize()

◆ GetCompressionFunction()

◆ GetDataType()

◆ HasParent()

◆ SetParent()

◆ Parent()

◆ GetType()

◆ GetSegmentTree()

◆ SetCount()

◆ Checkpoint()

◆ Cast() [1/2]

◆ Cast() [2/2]

Member Data Documentation

◆ compression