The LocalStorage class holds appends that have not been committed yet. More...

Collaboration diagram for duckdb::LocalStorage:

[legend]

Classes
struct	CommitState

Public Member Functions
	LocalStorage (ClientContext &context, DuckTransaction &transaction)

void	InitializeScan (DataTable &table, CollectionScanState &state, optional_ptr< TableFilterSet > table_filters)
	Initialize a scan of the local storage.

void	Scan (CollectionScanState &state, const vector< StorageIndex > &column_ids, DataChunk &result)
	Scan.

void	InitializeParallelScan (DataTable &table, ParallelCollectionScanState &state)

bool	NextParallelScan (ClientContext &context, DataTable &table, ParallelCollectionScanState &state, CollectionScanState &scan_state)

void	InitializeAppend (LocalAppendState &state, DataTable &table)
	Begin appending to the local storage.

void	InitializeStorage (LocalAppendState &state, DataTable &table)
	Initialize the storage and its indexes, but no row groups.

void	LocalMerge (DataTable &table, OptimisticWriteCollection &collection)
	Merge a row group collection into the transaction-local storage.

PhysicalIndex	CreateOptimisticCollection (DataTable &table, unique_ptr< OptimisticWriteCollection > collection)

OptimisticWriteCollection &	GetOptimisticCollection (DataTable &table, const PhysicalIndex collection_index)
	Returns the optimistic row group collection corresponding to the index.

void	ResetOptimisticCollection (DataTable &table, const PhysicalIndex collection_index)
	Resets the optimistic row group collection corresponding to the index.

OptimisticDataWriter &	GetOptimisticWriter (DataTable &table)
	Returns the optimistic writer.

idx_t	Delete (DataTable &table, Vector &row_ids, idx_t count)
	Delete a set of rows from the local storage.

void	Update (DataTable &table, Vector &row_ids, const vector< PhysicalIndex > &column_ids, DataChunk &data)
	Update a set of rows in the local storage.

void	Commit (optional_ptr< StorageCommitState > commit_state)
	Commits the local storage, writing it to the WAL and completing the commit.

void	Rollback ()
	Rollback the local storage.

bool	ChangesMade () noexcept

idx_t	EstimatedSize ()

void	DropTable (DataTable &table)

bool	Find (DataTable &table)

idx_t	AddedRows (DataTable &table)

vector< PartitionStatistics >	GetPartitionStats (DataTable &table) const

void	AddColumn (DataTable &old_dt, DataTable &new_dt, ColumnDefinition &new_column, ExpressionExecutor &default_executor)

void	DropColumn (DataTable &old_dt, DataTable &new_dt, const idx_t drop_column_index)

void	ChangeType (DataTable &old_dt, DataTable &new_dt, idx_t changed_idx, const LogicalType &target_type, const vector< StorageIndex > &bound_columns, Expression &cast_expr)

void	MoveStorage (DataTable &old_dt, DataTable &new_dt)

void	FetchChunk (DataTable &table, const Vector &row_ids, idx_t count, const vector< StorageIndex > &col_ids, DataChunk &chunk, ColumnFetchState &fetch_state)

bool	CanFetch (DataTable &table, const row_t row_id)
	Returns true, if the local storage contains the row id.

TableIndexList &	GetIndexes (ClientContext &context, DataTable &table)

optional_ptr< LocalTableStorage >	GetStorage (DataTable &table)

void	VerifyNewConstraint (DataTable &parent, const BoundConstraint &constraint)

ClientContext &	GetClientContext () const

Static Public Member Functions
static LocalStorage &	Get (DuckTransaction &transaction)

static LocalStorage &	Get (ClientContext &context, AttachedDatabase &db)

static LocalStorage &	Get (ClientContext &context, Catalog &catalog)

static void	Append (LocalAppendState &state, DataChunk &table_chunk, DataTableInfo &data_table_info)
	Append a chunk to the local storage.

static void	FinalizeAppend (LocalAppendState &state)
	Finish appending to the local storage.

Private Member Functions
void	Flush (DataTable &table, LocalTableStorage &storage, optional_ptr< StorageCommitState > commit_state)

Private Attributes
ClientContext &	context

DuckTransaction &	transaction

LocalTableManager	table_manager

Detailed Description

The LocalStorage class holds appends that have not been committed yet.

Member Function Documentation

◆ CreateOptimisticCollection()

PhysicalIndex duckdb::LocalStorage::CreateOptimisticCollection	(	DataTable &	table,
		unique_ptr< OptimisticWriteCollection >	collection
	)

Create an optimistic row group collection for this table. Returns the index into the optimistic_collections vector for newly created collection.

◆ GetClientContext()

ClientContext & duckdb::LocalStorage::GetClientContext ( ) const

inline

                                            {
        return context;
    }

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

external/duckdb/duckdb.hpp

Classes

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Function Documentation

◆ CreateOptimisticCollection()

◆ GetClientContext()