|
41 | 41 |
|
42 | 42 | namespace iceberg { |
43 | 43 |
|
| 44 | +namespace { |
| 45 | +const TimePointMs kInvalidLastUpdatedMs = TimePointMs::min(); |
| 46 | +} |
| 47 | + |
44 | 48 | std::string ToString(const SnapshotLogEntry& entry) { |
45 | 49 | return std::format("SnapshotLogEntry[timestampMillis={},snapshotId={}]", |
46 | 50 | entry.timestamp_ms, entry.snapshot_id); |
@@ -224,7 +228,7 @@ struct TableMetadataBuilder::Impl { |
224 | 228 | explicit Impl(int8_t format_version) : base(nullptr), metadata{} { |
225 | 229 | metadata.format_version = format_version; |
226 | 230 | metadata.last_sequence_number = TableMetadata::kInitialSequenceNumber; |
227 | | - metadata.last_updated_ms = TableMetadata::kInvalidLastUpdatedMs; |
| 231 | + metadata.last_updated_ms = kInvalidLastUpdatedMs; |
228 | 232 | metadata.last_column_id = Schema::kInvalidColumnId; |
229 | 233 | metadata.default_spec_id = PartitionSpec::kInitialSpecId; |
230 | 234 | metadata.last_partition_id = PartitionSpec::kInvalidPartitionFieldId; |
@@ -448,7 +452,7 @@ Result<std::unique_ptr<TableMetadata>> TableMetadataBuilder::Build() { |
448 | 452 | // 2. Validate metadata consistency through TableMetadata#Validate |
449 | 453 |
|
450 | 454 | // 3. Update last_updated_ms if there are changes |
451 | | - if (impl_->metadata.last_updated_ms == TableMetadata::kInvalidLastUpdatedMs) { |
| 455 | + if (impl_->metadata.last_updated_ms == kInvalidLastUpdatedMs) { |
452 | 456 | impl_->metadata.last_updated_ms = |
453 | 457 | TimePointMs{std::chrono::duration_cast<std::chrono::milliseconds>( |
454 | 458 | std::chrono::system_clock::now().time_since_epoch())}; |
|
0 commit comments