wip ict impl

kernel/src/actions/mod.rs

@@ -333,6 +333,7 @@ struct CommitInfo {
     /// Read: optional, write: required (that is, kernel always writes).
     /// If in-commit timestamps are enabled, this is always required.
     pub(crate) timestamp: Option<i64>,
+    pub(crate) in_commit_timestamp: Option<i64>,
     /// An arbitrary string that identifies the operation associated with this commit. This is
     /// specified by the engine. Read: optional, write: required (that is, kernel alwarys writes).
     pub(crate) operation: Option<String>,

kernel/src/table_changes/log_replay.rs

@@ -319,7 +319,7 @@ impl RowVisitor for PreparePhaseVisitor<'_> {
                 (INTEGER, column_name!("protocol.minWriterVersion")),
                 (string_list.clone(), column_name!("protocol.readerFeatures")),
                 (string_list, column_name!("protocol.writerFeatures")),
-                (LONG, column_name!("commitInfo.timestamp")),
+                (LONG, column_name!("commitInfo.inCommitTimestamp")),
             ];
             let (types, names) = types_and_names.into_iter().unzip();
             (names, types).into()
@@ -360,7 +360,9 @@ impl RowVisitor for PreparePhaseVisitor<'_> {
                 let protocol =
                     ProtocolVisitor::visit_protocol(i, min_reader_version, &getters[12..=15])?;
                 self.protocol = Some(protocol);
-            } else if let Some(timestamp) = getters[16].get_long(i, "commitInfo.timestamp")? {
+            } else if let Some(timestamp) =
+                getters[16].get_long(i, "commitInfo.inCommitTimestamp")?
+            {
                 *self.timestamp = timestamp;
             }
         }