iceberg-cpp
Loading...
Searching...
No Matches
iceberg::TestOverwriteUpdate Member List

This is the complete list of members for iceberg::TestOverwriteUpdate, including all inherited members.

AddDataFile(std::shared_ptr< DataFile > file)iceberg::MergingSnapshotUpdateprotected
AddDelete(std::shared_ptr< DataFile > file) (defined in iceberg::TestOverwriteUpdate)iceberg::TestOverwriteUpdateinline
AddDelete(std::shared_ptr< DataFile > file, int64_t data_sequence_number) (defined in iceberg::TestOverwriteUpdate)iceberg::TestOverwriteUpdateinline
AddDeleteFile(std::shared_ptr< DataFile > file)iceberg::MergingSnapshotUpdateprotected
AddDeleteFile(std::shared_ptr< DataFile > file, int64_t data_sequence_number)iceberg::MergingSnapshotUpdateprotected
AddedDataFiles() consticeberg::MergingSnapshotUpdateprotected
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::MergingSnapshotUpdateprotectedstatic
AddError(this auto &self, ErrorKind kind, const std::format_string< Args... > fmt, Args &&... args)iceberg::ErrorCollectorinline
AddError(this auto &self, Error err)iceberg::ErrorCollectorinline
AddError(this auto &self, std::unexpected< Error > err)iceberg::ErrorCollectorinline
AddManifest(ManifestFile manifest)iceberg::MergingSnapshotUpdateprotected
AddsDataFiles() consticeberg::MergingSnapshotUpdateprotected
AddsDeleteFiles() consticeberg::MergingSnapshotUpdateprotected
Apply(const TableMetadata &metadata_to_update, const std::shared_ptr< Snapshot > &snapshot) overrideiceberg::MergingSnapshotUpdatevirtual
iceberg::SnapshotUpdate::Apply()iceberg::SnapshotUpdate
attempt() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
base() const (defined in iceberg::PendingUpdate)iceberg::PendingUpdateprotected
BuildManifestCountSummary(std::span< const ManifestFile > manifests, int32_t replaced_manifests_count) (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
can_inherit_snapshot_id() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
CaseSensitive(bool case_sensitive)iceberg::MergingSnapshotUpdateprotected
CheckErrors() consticeberg::ErrorCollectorinline
CleanUncommitted(const std::unordered_set< std::string > &committed) overrideiceberg::MergingSnapshotUpdatevirtual
CleanupAfterCommit() consticeberg::SnapshotUpdateinlineprotectedvirtual
ClearErrors()iceberg::ErrorCollectorinline
Commit()iceberg::PendingUpdatevirtual
commit_uuid() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
ctx_ (defined in iceberg::PendingUpdate)iceberg::PendingUpdateprotected
DataSpec() consticeberg::MergingSnapshotUpdateprotected
DeleteByPath(std::string_view path)iceberg::MergingSnapshotUpdateprotected
DeleteByRowFilter(std::shared_ptr< Expression > expr)iceberg::MergingSnapshotUpdateprotected
DeleteDataFile(std::shared_ptr< DataFile > file)iceberg::MergingSnapshotUpdateprotected
DeleteDeleteFile(std::shared_ptr< DataFile > file)iceberg::MergingSnapshotUpdateprotected
DeleteFile(const std::string &path)iceberg::SnapshotUpdateprotected
DeletesDataFiles() consticeberg::MergingSnapshotUpdateprotected
DeletesDeleteFiles() consticeberg::MergingSnapshotUpdateprotected
DeleteWith(this auto &self, std::function< Status(const std::string &)> delete_func)iceberg::SnapshotUpdateinline
DropPartition(int32_t spec_id, PartitionValues partition)iceberg::MergingSnapshotUpdateprotected
error_count() consticeberg::ErrorCollectorinline
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() consticeberg::ErrorCollectorinline
errors_ (defined in iceberg::ErrorCollector)iceberg::ErrorCollectorprotected
FailAnyDelete()iceberg::MergingSnapshotUpdateprotected
FailMissingDeletePaths()iceberg::MergingSnapshotUpdateprotected
Finalize(Result< const TableMetadata * > commit_result) overrideiceberg::SnapshotUpdatevirtual
GeneratedSnapshotId() (defined in iceberg::TestOverwriteUpdate)iceberg::TestOverwriteUpdateinline
has_errors() consticeberg::ErrorCollectorinline
HasDataSequenceNumber() consticeberg::MergingSnapshotUpdateinlineprotected
IsCaseSensitive() consticeberg::MergingSnapshotUpdateinlineprotected
IsRetryable() const overrideiceberg::SnapshotUpdateinlinevirtual
kind() const overrideiceberg::SnapshotUpdateinlinevirtual
Kind enum name (defined in iceberg::PendingUpdate)iceberg::PendingUpdate
Make(std::string table_name, std::shared_ptr< Table > table) (defined in iceberg::TestOverwriteUpdate)iceberg::TestOverwriteUpdateinlinestatic
manifest_count() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
ManifestListPath() (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
ManifestPath() (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
MergingSnapshotUpdate(std::string table_name, std::shared_ptr< TransactionContext > ctx)iceberg::MergingSnapshotUpdateexplicitprotected
operation() overrideiceberg::TestOverwriteUpdateinlinevirtual
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::PendingUpdateexplicitprotected
RemoveDataFile(std::shared_ptr< DataFile > file) (defined in iceberg::TestOverwriteUpdate)iceberg::TestOverwriteUpdateinline
RowFilter() consticeberg::MergingSnapshotUpdateinlineprotected
ScanManifestsWith(this auto &self, Executor &executor)iceberg::SnapshotUpdateinline
Set(this auto &self, const std::string &property, const std::string &value)iceberg::SnapshotUpdateinline
SetNewDataFilesDataSequenceNumber(int64_t sequence_number)iceberg::MergingSnapshotUpdateprotected
SnapshotId()iceberg::SnapshotUpdateprotected
SnapshotUpdate(std::shared_ptr< TransactionContext > ctx) (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateexplicitprotected
StageOnly(this auto &self)iceberg::SnapshotUpdateinline
Summary() overrideiceberg::MergingSnapshotUpdatevirtual
summary_ (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
summary_builder() (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
target_branch() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
target_manifest_size_bytes() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
ToBranch(this auto &self, const std::string &branch)iceberg::SnapshotUpdateinline
Validate(const TableMetadata &current_metadata, const std::shared_ptr< Snapshot > &snapshot)iceberg::SnapshotUpdateinlineprotectedvirtual
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::MergingSnapshotUpdateprotectedstatic
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::MergingSnapshotUpdateprotectedstatic
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::MergingSnapshotUpdateprotectedstatic
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) consticeberg::MergingSnapshotUpdateprotected
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::MergingSnapshotUpdateprotectedstatic
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::MergingSnapshotUpdateprotectedstatic
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::MergingSnapshotUpdateprotectedstatic
ValidateNewDeleteFile(const TableMetadata &metadata, const DataFile &file)iceberg::MergingSnapshotUpdateprotected
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::MergingSnapshotUpdateprotectedstatic
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::MergingSnapshotUpdateprotectedstatic
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) consticeberg::MergingSnapshotUpdateinlineprotected
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::MergingSnapshotUpdateprotectedstatic
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::MergingSnapshotUpdateprotectedstatic
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::SnapshotUpdateprotected
WriteDeleteManifests(std::span< const ContentFileWithSequenceNumber > files, const std::shared_ptr< PartitionSpec > &spec) (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
WriteManifestsWith(this auto &self, Executor &executor, int32_t parallelism)iceberg::SnapshotUpdateinline
~ErrorCollector()=default (defined in iceberg::ErrorCollector)iceberg::ErrorCollectorvirtual
~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