datalake/coordinator: add hour to data file

redpanda-data · Oct 9, 2024 · 5fd7f69 · 5fd7f69
1 parent 0557f91
commit 5fd7f69
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/v/datalake/coordinator/data_file.cc b/src/v/datalake/coordinator/data_file.cc
@@ -13,10 +13,11 @@ namespace datalake::coordinator {
 
 std::ostream& operator<<(std::ostream& o, const data_file& f) {
     o << fmt::format(
-      "{{remote_path: {}, row_count: {}, file_size_bytes: {}}}",
+      "{{remote_path: {}, row_count: {}, file_size_bytes: {}, hour: {}}}",
       f.remote_path,
       f.row_count,
-      f.file_size_bytes);
+      f.file_size_bytes,
+      f.hour);
     return o;
 }
 

diff --git a/src/v/datalake/coordinator/data_file.h b/src/v/datalake/coordinator/data_file.h
@@ -22,11 +22,12 @@ namespace datalake::coordinator {
 struct data_file
   : serde::envelope<data_file, serde::version<0>, serde::compat_version<0>> {
     auto serde_fields() {
-        return std::tie(remote_path, row_count, file_size_bytes);
+        return std::tie(remote_path, row_count, file_size_bytes, hour);
     }
     ss::sstring remote_path = "";
     size_t row_count = 0;
     size_t file_size_bytes = 0;
+    int hour = 0;
     // TODO: add kafka schema id
 };