|
| 1 | +//===----------------------------------------------------------------------===// |
| 2 | +// DuckDB |
| 3 | +// |
| 4 | +// duckdb/storage/table/row_id_column_data.hpp |
| 5 | +// |
| 6 | +// |
| 7 | +//===----------------------------------------------------------------------===// |
| 8 | + |
| 9 | +#pragma once |
| 10 | + |
| 11 | +#include "duckdb/storage/table/column_data.hpp" |
| 12 | + |
| 13 | +namespace duckdb { |
| 14 | + |
| 15 | +class RowIdColumnData : public ColumnData { |
| 16 | +public: |
| 17 | + RowIdColumnData(BlockManager &block_manager, DataTableInfo &info, idx_t start_row); |
| 18 | + |
| 19 | +public: |
| 20 | + void InitializePrefetch(PrefetchState &prefetch_state, ColumnScanState &scan_state, idx_t rows) override; |
| 21 | + void InitializeScan(ColumnScanState &state) override; |
| 22 | + void InitializeScanWithOffset(ColumnScanState &state, idx_t row_idx) override; |
| 23 | + |
| 24 | + idx_t Scan(TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, |
| 25 | + idx_t scan_count) override; |
| 26 | + idx_t ScanCommitted(idx_t vector_index, ColumnScanState &state, Vector &result, bool allow_updates, |
| 27 | + idx_t scan_count) override; |
| 28 | + void ScanCommittedRange(idx_t row_group_start, idx_t offset_in_row_group, idx_t count, Vector &result) override; |
| 29 | + idx_t ScanCount(ColumnScanState &state, Vector &result, idx_t count, idx_t result_offset = 0) override; |
| 30 | + |
| 31 | + void Filter(TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, |
| 32 | + SelectionVector &sel, idx_t &count, const TableFilter &filter, TableFilterState &filter_state) override; |
| 33 | + void Select(TransactionData transaction, idx_t vector_index, ColumnScanState &state, Vector &result, |
| 34 | + SelectionVector &sel, idx_t count) override; |
| 35 | + void SelectCommitted(idx_t vector_index, ColumnScanState &state, Vector &result, SelectionVector &sel, idx_t count, |
| 36 | + bool allow_updates) override; |
| 37 | + |
| 38 | + idx_t Fetch(ColumnScanState &state, row_t row_id, Vector &result) override; |
| 39 | + void FetchRow(TransactionData transaction, ColumnFetchState &state, row_t row_id, Vector &result, |
| 40 | + idx_t result_idx) override; |
| 41 | + |
| 42 | + void Skip(ColumnScanState &state, idx_t count = STANDARD_VECTOR_SIZE) override; |
| 43 | + |
| 44 | + FilterPropagateResult CheckZonemap(ColumnScanState &state, TableFilter &filter) override; |
| 45 | + |
| 46 | + void InitializeAppend(ColumnAppendState &state) override; |
| 47 | + void Append(BaseStatistics &stats, ColumnAppendState &state, Vector &vector, idx_t count) override; |
| 48 | + void AppendData(BaseStatistics &stats, ColumnAppendState &state, UnifiedVectorFormat &vdata, idx_t count) override; |
| 49 | + void RevertAppend(row_t start_row) override; |
| 50 | + |
| 51 | + void Update(TransactionData transaction, idx_t column_index, Vector &update_vector, row_t *row_ids, |
| 52 | + idx_t update_count) override; |
| 53 | + void UpdateColumn(TransactionData transaction, const vector<column_t> &column_path, Vector &update_vector, |
| 54 | + row_t *row_ids, idx_t update_count, idx_t depth) override; |
| 55 | + |
| 56 | + void CommitDropColumn() override; |
| 57 | + |
| 58 | + unique_ptr<ColumnCheckpointState> CreateCheckpointState(RowGroup &row_group, |
| 59 | + PartialBlockManager &partial_block_manager) override; |
| 60 | + unique_ptr<ColumnCheckpointState> Checkpoint(RowGroup &row_group, ColumnCheckpointInfo &info) override; |
| 61 | + |
| 62 | + void CheckpointScan(ColumnSegment &segment, ColumnScanState &state, idx_t row_group_start, idx_t count, |
| 63 | + Vector &scan_vector) override; |
| 64 | + |
| 65 | + bool IsPersistent() override; |
| 66 | +}; |
| 67 | + |
| 68 | +} // namespace duckdb |
0 commit comments