Lines Matching refs:manifest
402 const DeltaArchiveManifest& manifest, in PreparePartitionsForUpdate() argument
440 is_target_dynamic_ = !manifest.dynamic_partition_metadata().groups().empty(); in PreparePartitionsForUpdate()
446 manifest.dynamic_partition_metadata().snapshot_enabled(); in PreparePartitionsForUpdate()
462 source_slot, target_slot, manifest, required_size)) { in PreparePartitionsForUpdate()
500 source_slot, target_slot, manifest, delete_source)); in PreparePartitionsForUpdate()
721 const DeltaArchiveManifest& manifest, in PrepareDynamicPartitionsForUpdate() argument
727 for (const auto& group : manifest.dynamic_partition_metadata().groups()) { in PrepareDynamicPartitionsForUpdate()
752 DeleteSourcePartitions(builder.get(), source_slot, manifest)); in PrepareDynamicPartitionsForUpdate()
755 if (!UpdatePartitionMetadata(builder.get(), target_slot, manifest)) { in PrepareDynamicPartitionsForUpdate()
767 const DeltaArchiveManifest& manifest, in PrepareSnapshotPartitionsForUpdate() argument
774 auto ret = snapshot_->CreateUpdateSnapshots(manifest); in PrepareSnapshotPartitionsForUpdate()
794 const DeltaArchiveManifest& manifest) { in UpdatePartitionMetadata() argument
804 for (const auto& group : manifest.dynamic_partition_metadata().groups()) { in UpdatePartitionMetadata()
824 for (const auto& partition : manifest.partitions()) { in UpdatePartitionMetadata()
829 for (const auto& group : manifest.dynamic_partition_metadata().groups()) { in UpdatePartitionMetadata()
1018 static bool IsIncrementalUpdate(const DeltaArchiveManifest& manifest) { in IsIncrementalUpdate() argument
1019 const auto& partitions = manifest.partitions(); in IsIncrementalUpdate()
1028 const DeltaArchiveManifest& manifest) { in DeleteSourcePartitions() argument
1031 if (IsIncrementalUpdate(manifest)) { in DeleteSourcePartitions()