Skip to content

Commit

Permalink
model: datalake_coordinator batch type
Browse files Browse the repository at this point in the history
For use by the upcoming datalake coordinator STM to track files that
need to be committed to Iceberg.
  • Loading branch information
andrwng committed Oct 9, 2024
1 parent 4ce066f commit 68c7ea2
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
2 changes: 2 additions & 0 deletions src/v/model/model.cc
Original file line number Diff line number Diff line change
Expand Up @@ -388,6 +388,8 @@ std::ostream& operator<<(std::ostream& o, record_batch_type bt) {
return o << "batch_type::group_fence_tx";
case record_batch_type::partition_properties_update:
return o << "batch_type::partition_properties_update";
case record_batch_type::datalake_coordinator:
return o << "batch_type::datalake_coordinator";
}

return o << "batch_type::unknown{" << static_cast<int>(bt) << "}";
Expand Down
3 changes: 2 additions & 1 deletion src/v/model/record_batch_types.h
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,8 @@ enum class record_batch_type : int8_t {
group_fence_tx = 33, // fence batch in group transactions
partition_properties_update
= 34, // special batch type used to update partition properties
MAX = group_fence_tx,
datalake_coordinator = 35, // datalake::coordinator::*
MAX = datalake_coordinator,
};

std::ostream& operator<<(std::ostream& o, record_batch_type bt);
Expand Down

0 comments on commit 68c7ea2

Please sign in to comment.