Merge branch 'add_output_stream_and_serializers' of https://github.com/Alex-PLACET/sparrow-ipc into add_output_stream_and_serializers

Alex-PLACET · Alex-PLACET · commit 14952d0a88f5 · 2025-10-06T16:03:27.000+02:00
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`	`}`