Skip to content

Commit 43afc3a

Browse files
feat: Distributed Log Replay serialization/deserialization (delta-io#1503)
## What changes are proposed in this pull request? This PR introduces serialization and deserialization for the ScanLogReplayProcessor. <!-- Uncomment this section if there are any changes affecting public APIs: ### This PR affects the following public APIs If there are breaking changes, please ensure the `breaking-changes` label gets added by CI, and describe why the changes are needed. Note that _new_ public APIs are not considered breaking. --> This PR adds serialization and deserialization for LogReplayProcessor. ## How was this change tested? <!-- Please make sure to add test cases that check the changes thoroughly including negative and positive cases if possible. If it was tested in a way different from regular unit tests, please clarify how you tested, ideally via a reproducible test documented in the PR description. --> Round trip test is performed with the LogReplayProcessor. Invalid internal state is expected to result in an error.
1 parent a540c0b commit 43afc3a

4 files changed

Lines changed: 410 additions & 12 deletions

File tree

kernel/src/log_replay.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ use tracing::debug;
2626

2727
/// The subset of file action fields that uniquely identifies it in the log, used for deduplication
2828
/// of adds and removes during log replay.
29-
#[derive(Debug, Hash, Eq, PartialEq, Clone)]
30-
pub(crate) struct FileActionKey {
29+
#[derive(Debug, Hash, Eq, PartialEq, serde::Serialize, serde::Deserialize, Clone)]
30+
pub struct FileActionKey {
3131
pub(crate) path: String,
3232
pub(crate) dv_unique_id: Option<String>,
3333
}

0 commit comments

Comments
 (0)