Skip to content

Commit 14c3387

Browse files
authored
chore: public function generate_unique_snapshot_id for exactly once sink (#42)
* public txn.generate_unique_snapshot_id * add comment * empty commit for retry
1 parent c9da916 commit 14c3387

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

crates/iceberg/src/spec/manifest/_serde.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ impl ManifestEntryV1 {
9797
}
9898

9999
#[serde_as]
100-
#[derive(Serialize, Deserialize)]
100+
#[derive(Serialize, Deserialize, Clone)]
101101
/// Data file
102102
pub struct DataFileSerde {
103103
#[serde(default)]

crates/iceberg/src/transaction/mod.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,8 @@ impl<'a> Transaction<'a> {
131131
Ok(self)
132132
}
133133

134-
fn generate_unique_snapshot_id(&self) -> i64 {
134+
/// Generate a new `snapshot_id`.
135+
pub fn generate_unique_snapshot_id(&self) -> i64 {
135136
let generate_random_id = || -> i64 {
136137
let (lhs, rhs) = Uuid::new_v4().as_u64_pair();
137138
let snapshot_id = (lhs ^ rhs) as i64;

0 commit comments

Comments
 (0)