Update include/sparrow_ipc/serializer.hpp

Alex-PLACET · Copilot · Alex-PLACET · commit 75c982715769 · 2025-10-07T14:40:57.000+02:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/include/sparrow_ipc/serializer.hpp b/include/sparrow_ipc/serializer.hpp
@@ -109,6 +109,10 @@ namespace sparrow_ipc
             m_pstream->reserve(reserve_function);
             for (const auto& rb : record_batches)
             {
+                if (get_column_dtypes(rb) != m_dtypes)
+                {
+                    throw std::invalid_argument("Record batch schema does not match serializer schema");
+                }
                 serialize_record_batch(rb, *m_pstream);
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -109,6 +109,10 @@ namespace sparrow_ipc`
`109`	`109`	`m_pstream->reserve(reserve_function);`
`110`	`110`	`for (const auto& rb : record_batches)`
`111`	`111`	`{`
	`112`	`+ if (get_column_dtypes(rb) != m_dtypes)`
	`113`	`+ {`
	`114`	`+ throw std::invalid_argument("Record batch schema does not match serializer schema");`
	`115`	`+ }`
`112`	`116`	`serialize_record_batch(rb, *m_pstream);`
`113`	`117`	`}`
`114`	`118`	`}`