@@ -204,15 +204,15 @@ impl Transaction {
204
204
205
205
// Step 3: Generate add actions and get data for domain metadata actions (e.g. row tracking high watermark)
206
206
let commit_version = self . read_snapshot . version ( ) + 1 ;
207
- let ( add_actions, row_tracking_high_watermark ) =
207
+ let ( add_actions, row_tracking_domain_metadata ) =
208
208
self . generate_adds ( engine, commit_version) ?;
209
209
210
210
// Step 4: Generate all domain metadata actions (user and system domains)
211
211
let domain_metadata_actions = Self :: generate_domain_metadata_actions (
212
212
engine,
213
213
& self . domain_metadatas ,
214
214
& self . read_snapshot ,
215
- row_tracking_high_watermark ,
215
+ row_tracking_domain_metadata ,
216
216
) ?;
217
217
218
218
// Step 5: Commit the actions as a JSON file to the Delta log
@@ -272,7 +272,7 @@ impl Transaction {
272
272
/// Set domain metadata to be written to the Delta log.
273
273
/// Note that each domain can only appear once per transaction. That is, multiple configurations
274
274
/// of the same domain are disallowed in a single transaction, as well as setting and removing
275
- /// the same domain in a single transaction. If a duplicate domain is included, the ` commit` will
275
+ /// the same domain in a single transaction. If a duplicate domain is included, the commit will
276
276
/// fail (that is, we don't eagerly check domain validity here).
277
277
pub fn with_domain_metadata ( mut self , domain : String , configuration : String ) -> Self {
278
278
self . domain_metadatas
0 commit comments