Use stream file serializer and deserializer

Author: Alex-PLACET

integration_tests/arrow_file_to_stream.cpp

@@ -10,7 +10,7 @@
 #include "sparrow/json_reader/json_parser.hpp"
 
 #include <sparrow_ipc/memory_output_stream.hpp>
-#include <sparrow_ipc/serializer.hpp>
+#include <sparrow_ipc/stream_file_serializer.hpp>
 
 /**
  * @brief Reads a JSON file containing record batches and outputs the serialized Arrow IPC stream to stdout.
@@ -98,9 +98,9 @@ int main(int argc, char* argv[])
         // Serialize record batches to Arrow IPC stream format
         std::vector<uint8_t> stream_data;
         sparrow_ipc::memory_output_stream stream(stream_data);
-        sparrow_ipc::serializer serializer(stream);
-
-        serializer << record_batches << sparrow_ipc::end_stream;
+        sparrow_ipc::stream_file_serializer serializer(stream);
+        serializer << record_batches;
+        serializer.end();
 
         // Write the binary stream to stdout
         std::cout.write(reinterpret_cast<const char*>(stream_data.data()), stream_data.size());

integration_tests/arrow_json_to_file.cpp

@@ -6,7 +6,7 @@
 
 #include <nlohmann/json.hpp>
 #include <sparrow_ipc/memory_output_stream.hpp>
-#include <sparrow_ipc/serializer.hpp>
+#include <sparrow_ipc/stream_file_serializer.hpp>
 
 #include <sparrow/json_reader/json_parser.hpp>
 #include <sparrow/record_batch.hpp>
@@ -97,9 +97,9 @@ int main(int argc, char* argv[])
         // Serialize record batches to Arrow IPC stream format
         std::vector<uint8_t> stream_data;
         sparrow_ipc::memory_output_stream stream(stream_data);
-        sparrow_ipc::serializer serializer(stream);
-
-        serializer << record_batches << sparrow_ipc::end_stream;
+        sparrow_ipc::stream_file_serializer serializer(stream);
+        serializer << record_batches;
+        serializer.end();
 
         // Write the binary stream to the output file
         std::ofstream output_file(output_path, std::ios::out | std::ios::binary);

integration_tests/arrow_stream_to_file.cpp

@@ -7,7 +7,7 @@
 
 #include <sparrow_ipc/deserialize.hpp>
 #include <sparrow_ipc/memory_output_stream.hpp>
-#include <sparrow_ipc/serializer.hpp>
+#include <sparrow_ipc/stream_file_serializer.hpp>
 
 /**
  * @brief Reads an Arrow IPC stream from a file and writes it to another file.
@@ -79,9 +79,9 @@ int main(int argc, char* argv[])
         // Re-serialize the record batches to ensure a valid output stream
         std::vector<uint8_t> output_stream_data;
         sparrow_ipc::memory_output_stream stream(output_stream_data);
-        sparrow_ipc::serializer serializer(stream);
-
-        serializer << record_batches << sparrow_ipc::end_stream;
+        sparrow_ipc::stream_file_serializer serializer(stream);
+        serializer << record_batches;
+        serializer.end();
 
         // Write the stream to the output file
         std::ofstream output_file(output_path, std::ios::out | std::ios::binary);