A scan that reads changelog entries between snapshots. More...
#include <table_scan.h>
Inheritance diagram for iceberg::IncrementalChangelogScan:
Public Member Functions | |
| Result< std::vector< std::shared_ptr< ChangelogScanTask > > > | PlanFiles () const override |
 Public Member Functions inherited from iceberg::TableScan | |
| const std::shared_ptr< TableMetadata > & | metadata () const |
| Returns the table metadata being scanned. | |
| Result< std::shared_ptr< Snapshot > > | snapshot () const |
| Returns the snapshot to scan. If there is no snapshot, returns nullptr. | |
| Result< std::shared_ptr< Schema > > | schema () const |
| Returns the projected schema for the scan. | |
| const internal::TableScanContext & | context () const |
| Returns the scan context. | |
| const std::shared_ptr< FileIO > & | io () const |
| Returns the file I/O instance used for reading files. | |
| const std::shared_ptr< Expression > & | filter () const |
| Returns this scan's filter expression. | |
| bool | is_case_sensitive () const |
| Returns whether this scan is case-sensitive. | |
Static Public Member Functions | |
| static Result< std::unique_ptr< IncrementalChangelogScan > > | Make (std::shared_ptr< TableMetadata > metadata, std::shared_ptr< Schema > schema, std::shared_ptr< FileIO > io, internal::TableScanContext context) |
| Constructs an IncrementalChangelogScan instance. | |
Protected Member Functions | |
| Result< std::vector< std::shared_ptr< ChangelogScanTask > > > | PlanFiles (std::optional< int64_t > from_snapshot_id_exclusive, int64_t to_snapshot_id_inclusive) const override |
| Protected Member Functions inherited from iceberg::IncrementalScan< ChangelogScanTask > | |
| TableScan (std::shared_ptr< TableMetadata > metadata, std::shared_ptr< Schema > schema, std::shared_ptr< FileIO > io, internal::TableScanContext context) | |
| Protected Member Functions inherited from iceberg::TableScan | |
| TableScan (std::shared_ptr< TableMetadata > metadata, std::shared_ptr< Schema > schema, std::shared_ptr< FileIO > io, internal::TableScanContext context) | |
| Result< std::reference_wrapper< const std::shared_ptr< Schema > > > | ResolveProjectedSchema () const |
| virtual const std::vector< std::string > & | ScanColumns () const |
Additional Inherited Members | |
| Protected Attributes inherited from iceberg::TableScan | |
| const std::shared_ptr< TableMetadata > | metadata_ |
| const std::shared_ptr< Schema > | schema_ |
| const std::shared_ptr< FileIO > | io_ |
| const internal::TableScanContext | context_ |
| std::shared_ptr< Schema > | projected_schema_ |
Detailed Description
A scan that reads changelog entries between snapshots.
Member Function Documentation
◆ PlanFiles() [1/2]
|
overridevirtual |
Implements iceberg::IncrementalScan< ChangelogScanTask >.
◆ PlanFiles() [2/2]
|
overrideprotectedvirtual |
Implements iceberg::IncrementalScan< ChangelogScanTask >.
The documentation for this class was generated from the following files:
- iceberg/table_scan.h
- iceberg/table_scan.cc
