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

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

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, ::iceberg::unexpected< Error > err)iceberg::ErrorCollectorinline
AddError(this auto &self, std::unexpected< Error > err) (defined in iceberg::ErrorCollector)iceberg::ErrorCollectorinline
AppendFile(const std::shared_ptr< DataFile > &file)iceberg::FastAppend
AppendManifest(const ManifestFile &manifest)iceberg::FastAppend
Apply(const TableMetadata &metadata_to_update, const std::shared_ptr< Snapshot > &snapshot) overrideiceberg::FastAppendprotectedvirtual
iceberg::SnapshotUpdate::Apply()iceberg::SnapshotUpdateprotectedvirtual
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
CheckCommitAllowed() const (defined in iceberg::PendingUpdate)iceberg::PendingUpdateprotected
CheckErrors() consticeberg::ErrorCollectorinline
CleanStaged() overrideiceberg::SnapshotUpdateprotectedvirtual
CleanUncommitted(const std::unordered_set< std::string > &committed) overrideiceberg::FastAppendprotectedvirtual
ClearErrors()iceberg::ErrorCollectorinline
Commit() overrideiceberg::SnapshotUpdatevirtual
commit_uuid() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
ctx_ (defined in iceberg::PendingUpdate)iceberg::PendingUpdateprotected
DeleteFile(const std::string &path) noexcepticeberg::SnapshotUpdateprotected
DeleteWith(this auto &self, std::function< Status(const std::string &)> delete_func)iceberg::SnapshotUpdateinline
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
Finalize(const TableMetadata &committed) overrideiceberg::SnapshotUpdateprotectedvirtual
has_errors() consticeberg::ErrorCollectorinline
IsRetryable() const overrideiceberg::SnapshotUpdateinlinevirtual
Kind enum name (defined in iceberg::PendingUpdate)iceberg::PendingUpdate
kind() const overrideiceberg::SnapshotUpdateinlinevirtual
Make(std::string table_name, std::shared_ptr< TransactionContext > ctx)iceberg::FastAppendstatic
manifest_count() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
ManifestListPath() (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
ManifestPath() (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
operation() overrideiceberg::FastAppendprotectedvirtual
operator=(const PendingUpdate &)=delete (defined in iceberg::PendingUpdate)iceberg::PendingUpdate
operator=(PendingUpdate &&)=delete (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 &&)=delete (defined in iceberg::PendingUpdate)iceberg::PendingUpdate
PendingUpdate(std::shared_ptr< TransactionContext > ctx) (defined in iceberg::PendingUpdate)iceberg::PendingUpdateexplicitprotected
plan_executor() const (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateinlineprotected
RegisterStagedFile(const std::string &path) (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateprotected
ReportWith(this auto &self, std::shared_ptr< MetricsReporter > reporter)iceberg::SnapshotUpdateinline
ScanManifestsWith(this auto &self, Executor &executor)iceberg::SnapshotUpdateinline
Set(this auto &self, const std::string &property, const std::string &value)iceberg::SnapshotUpdateinline
SetSummaryProperty(const std::string &property, const std::string &value) overrideiceberg::FastAppendprotectedvirtual
SnapshotId()iceberg::SnapshotUpdateprotected
SnapshotUpdate(std::shared_ptr< TransactionContext > ctx) (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdateexplicitprotected
StageOnly(this auto &self)iceberg::SnapshotUpdateinline
Summary() overrideiceberg::FastAppendprotectedvirtual
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
UnregisterStagedFile(const std::string &path)iceberg::SnapshotUpdateprotected
Validate(const TableMetadata &current_metadata, const std::shared_ptr< Snapshot > &snapshot)iceberg::SnapshotUpdateinlineprotectedvirtual
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
~PendingUpdate() override (defined in iceberg::PendingUpdate)iceberg::PendingUpdate
~SnapshotUpdate() override (defined in iceberg::SnapshotUpdate)iceberg::SnapshotUpdate