|
iceberg-cpp
|
This is the complete list of members for iceberg::RowDelta, including all inherited members.
| AddDataFile(std::shared_ptr< DataFile > file) | iceberg::MergingSnapshotUpdate | protected |
| AddDeleteFile(std::shared_ptr< DataFile > file) | iceberg::MergingSnapshotUpdate | protected |
| AddDeleteFile(std::shared_ptr< DataFile > file, int64_t data_sequence_number) | iceberg::MergingSnapshotUpdate | protected |
| AddDeletes(const std::shared_ptr< DataFile > &deletes) | iceberg::RowDelta | |
| AddedDataFiles() const | iceberg::MergingSnapshotUpdate | protected |
| AddedDeleteFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, std::shared_ptr< Expression > data_filter, std::shared_ptr< PartitionSet > partition_set, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool case_sensitive=true) | iceberg::MergingSnapshotUpdate | protectedstatic |
| AddError(this auto &self, ErrorKind kind, const std::format_string< Args... > fmt, Args &&... args) | iceberg::ErrorCollector | inline |
| AddError(this auto &self, Error err) | iceberg::ErrorCollector | inline |
| AddError(this auto &self, std::unexpected< Error > err) | iceberg::ErrorCollector | inline |
| AddManifest(ManifestFile manifest) | iceberg::MergingSnapshotUpdate | protected |
| AddRows(const std::shared_ptr< DataFile > &inserts) | iceberg::RowDelta | |
| AddsDataFiles() const | iceberg::MergingSnapshotUpdate | protected |
| AddsDeleteFiles() const | iceberg::MergingSnapshotUpdate | protected |
| Apply(const TableMetadata &metadata_to_update, const std::shared_ptr< Snapshot > &snapshot) override | iceberg::MergingSnapshotUpdate | virtual |
| iceberg::SnapshotUpdate::Apply() | iceberg::SnapshotUpdate | |
| attempt() const (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | inlineprotected |
| base() const (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | protected |
| BuildManifestCountSummary(std::span< const ManifestFile > manifests, int32_t replaced_manifests_count) (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | protected |
| can_inherit_snapshot_id() const (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | inlineprotected |
| CaseSensitive(bool case_sensitive) | iceberg::RowDelta | |
| CheckErrors() const | iceberg::ErrorCollector | inline |
| CleanUncommitted(const std::unordered_set< std::string > &committed) override | iceberg::MergingSnapshotUpdate | virtual |
| CleanupAfterCommit() const | iceberg::SnapshotUpdate | inlineprotectedvirtual |
| ClearErrors() | iceberg::ErrorCollector | inline |
| Commit() | iceberg::PendingUpdate | virtual |
| commit_uuid() const (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | inlineprotected |
| ConflictDetectionFilter(std::shared_ptr< Expression > filter) | iceberg::RowDelta | |
| ctx_ (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | protected |
| DataSpec() const | iceberg::MergingSnapshotUpdate | protected |
| DeleteByPath(std::string_view path) | iceberg::MergingSnapshotUpdate | protected |
| DeleteByRowFilter(std::shared_ptr< Expression > expr) | iceberg::MergingSnapshotUpdate | protected |
| DeleteDataFile(std::shared_ptr< DataFile > file) | iceberg::MergingSnapshotUpdate | protected |
| DeleteDeleteFile(std::shared_ptr< DataFile > file) | iceberg::MergingSnapshotUpdate | protected |
| DeleteFile(const std::string &path) | iceberg::SnapshotUpdate | protected |
| DeletesDataFiles() const | iceberg::MergingSnapshotUpdate | protected |
| DeletesDeleteFiles() const | iceberg::MergingSnapshotUpdate | protected |
| DeleteWith(this auto &self, std::function< Status(const std::string &)> delete_func) | iceberg::SnapshotUpdate | inline |
| DropPartition(int32_t spec_id, PartitionValues partition) | iceberg::MergingSnapshotUpdate | protected |
| error_count() const | iceberg::ErrorCollector | inline |
| ErrorCollector()=default (defined in iceberg::ErrorCollector) | iceberg::ErrorCollector | |
| ErrorCollector(ErrorCollector &&)=default (defined in iceberg::ErrorCollector) | iceberg::ErrorCollector | |
| ErrorCollector(const ErrorCollector &)=default (defined in iceberg::ErrorCollector) | iceberg::ErrorCollector | |
| errors() const | iceberg::ErrorCollector | inline |
| errors_ (defined in iceberg::ErrorCollector) | iceberg::ErrorCollector | protected |
| FailAnyDelete() | iceberg::MergingSnapshotUpdate | protected |
| FailMissingDeletePaths() | iceberg::MergingSnapshotUpdate | protected |
| Finalize(Result< const TableMetadata * > commit_result) override | iceberg::SnapshotUpdate | virtual |
| has_errors() const | iceberg::ErrorCollector | inline |
| HasDataSequenceNumber() const | iceberg::MergingSnapshotUpdate | inlineprotected |
| IsCaseSensitive() const | iceberg::MergingSnapshotUpdate | inlineprotected |
| IsRetryable() const override | iceberg::SnapshotUpdate | inlinevirtual |
| Kind enum name (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | |
| kind() const override | iceberg::SnapshotUpdate | inlinevirtual |
| Make(std::string table_name, std::shared_ptr< TransactionContext > ctx) | iceberg::RowDelta | static |
| manifest_count() const (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | inlineprotected |
| ManifestListPath() (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | protected |
| ManifestPath() (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | protected |
| MergingSnapshotUpdate(std::string table_name, std::shared_ptr< TransactionContext > ctx) | iceberg::MergingSnapshotUpdate | explicitprotected |
| operation() override | iceberg::RowDelta | virtual |
| operator=(const PendingUpdate &)=delete (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | |
| operator=(PendingUpdate &&) noexcept=default (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | |
| operator=(ErrorCollector &&)=default (defined in iceberg::ErrorCollector) | iceberg::ErrorCollector | |
| operator=(const ErrorCollector &)=default (defined in iceberg::ErrorCollector) | iceberg::ErrorCollector | |
| PendingUpdate(const PendingUpdate &)=delete (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | |
| PendingUpdate(PendingUpdate &&) noexcept=default (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | |
| PendingUpdate(std::shared_ptr< TransactionContext > ctx) (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | explicitprotected |
| RemoveDeletes(const std::shared_ptr< DataFile > &deletes) | iceberg::RowDelta | |
| RemoveRows(const std::shared_ptr< DataFile > &file) | iceberg::RowDelta | |
| RowFilter() const | iceberg::MergingSnapshotUpdate | inlineprotected |
| ScanManifestsWith(this auto &self, Executor &executor) | iceberg::SnapshotUpdate | inline |
| Set(this auto &self, const std::string &property, const std::string &value) | iceberg::SnapshotUpdate | inline |
| SetNewDataFilesDataSequenceNumber(int64_t sequence_number) | iceberg::MergingSnapshotUpdate | protected |
| SnapshotId() | iceberg::SnapshotUpdate | protected |
| SnapshotUpdate(std::shared_ptr< TransactionContext > ctx) (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | explicitprotected |
| StageOnly(this auto &self) | iceberg::SnapshotUpdate | inline |
| Summary() override | iceberg::MergingSnapshotUpdate | virtual |
| summary_ (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | protected |
| summary_builder() (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | inlineprotected |
| target_branch() const (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | inlineprotected |
| target_manifest_size_bytes() const (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | inlineprotected |
| ToBranch(this auto &self, const std::string &branch) | iceberg::SnapshotUpdate | inline |
| Validate(const TableMetadata ¤t_metadata, const std::shared_ptr< Snapshot > &snapshot) override | iceberg::RowDelta | protectedvirtual |
| ValidateAddedDataFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, std::shared_ptr< Expression > filter, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool case_sensitive=true) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateAddedDataFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, const PartitionSet &partition_set, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateAddedDVs(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, std::shared_ptr< Expression > conflict_filter, const std::unordered_set< std::string > &referenced_data_files, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool case_sensitive=true) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateAddedDVs(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, std::shared_ptr< Expression > conflict_filter, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io) const | iceberg::MergingSnapshotUpdate | protected |
| ValidateDataFilesExist(std::span< const std::string > referenced_files) | iceberg::RowDelta | |
| iceberg::MergingSnapshotUpdate::ValidateDataFilesExist(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, const std::unordered_set< std::string > &file_paths, bool skip_deletes, std::shared_ptr< Expression > filter, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool case_sensitive=true) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateDeletedDataFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, std::shared_ptr< Expression > data_filter, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool case_sensitive=true) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateDeletedDataFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, const PartitionSet &partition_set, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateDeletedFiles() | iceberg::RowDelta | |
| ValidateFromSnapshot(int64_t snapshot_id) | iceberg::RowDelta | |
| ValidateNewDeleteFile(const TableMetadata &metadata, const DataFile &file) | iceberg::MergingSnapshotUpdate | protected |
| ValidateNoConflictingDataFiles() | iceberg::RowDelta | |
| ValidateNoConflictingDeleteFiles() | iceberg::RowDelta | |
| ValidateNoNewDeleteFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, std::shared_ptr< Expression > data_filter, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool case_sensitive=true) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateNoNewDeleteFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, const PartitionSet &partition_set, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateNoNewDeletesForDataFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, const DataFileSet &replaced_files, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io) const | iceberg::MergingSnapshotUpdate | inlineprotected |
| ValidateNoNewDeletesForDataFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, const DataFileSet &replaced_files, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool ignore_equality_deletes=false) | iceberg::MergingSnapshotUpdate | protectedstatic |
| ValidateNoNewDeletesForDataFiles(const TableMetadata &metadata, std::optional< int64_t > starting_snapshot_id, std::shared_ptr< Expression > data_filter, const DataFileSet &replaced_files, const std::shared_ptr< Snapshot > &parent, std::shared_ptr< FileIO > io, bool case_sensitive=true) | iceberg::MergingSnapshotUpdate | protectedstatic |
| WriteDataManifests(std::span< const std::shared_ptr< DataFile > > files, const std::shared_ptr< PartitionSpec > &spec, std::optional< int64_t > data_sequence_number=std::nullopt) | iceberg::SnapshotUpdate | protected |
| WriteDeleteManifests(std::span< const ContentFileWithSequenceNumber > files, const std::shared_ptr< PartitionSpec > &spec) (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate | protected |
| WriteManifestsWith(this auto &self, Executor &executor, int32_t parallelism) | iceberg::SnapshotUpdate | inline |
| ~ErrorCollector()=default (defined in iceberg::ErrorCollector) | iceberg::ErrorCollector | virtual |
| ~MergingSnapshotUpdate() override=default (defined in iceberg::MergingSnapshotUpdate) | iceberg::MergingSnapshotUpdate | |
| ~PendingUpdate() override (defined in iceberg::PendingUpdate) | iceberg::PendingUpdate | |
| ~SnapshotUpdate() override (defined in iceberg::SnapshotUpdate) | iceberg::SnapshotUpdate |
1.9.8