serialize.hpp File Reference

#include <ranges>
#include <sparrow/record_batch.hpp>
#include "sparrow_ipc/any_output_stream.hpp"
#include "sparrow_ipc/compression.hpp"
#include "sparrow_ipc/config/config.hpp"
#include "sparrow_ipc/magic_values.hpp"
#include "sparrow_ipc/serialize_utils.hpp"
#include "sparrow_ipc/utils.hpp"

Include dependency graph for serialize.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	sparrow_ipc::serialized_record_batch_info
	Information about a serialized record batch block. More...

Namespaces
namespace	sparrow_ipc

Functions
template<std::ranges::input_range R> requires std::same_as<std::ranges::range_value_t<R>, sparrow::record_batch>
void	sparrow_ipc::serialize_record_batches_to_ipc_stream (const R &record_batches, any_output_stream &stream, std::optional< CompressionType > compression, std::optional< std::reference_wrapper< CompressionCache > > cache)
	Serializes a collection of record batches into a binary format.
SPARROW_IPC_API serialized_record_batch_info	sparrow_ipc::serialize_record_batch (const sparrow::record_batch &record_batch, any_output_stream &stream, std::optional< CompressionType > compression, std::optional< std::reference_wrapper< CompressionCache > > cache)
	Serializes a record batch into a binary format following the Arrow IPC specification.
SPARROW_IPC_API serialized_record_batch_info	sparrow_ipc::serialize_dictionary_batch (int64_t dictionary_id, const sparrow::record_batch &record_batch, bool is_delta, any_output_stream &stream, std::optional< CompressionType > compression, std::optional< std::reference_wrapper< CompressionCache > > cache)
	Serializes a dictionary batch into a binary format following the Arrow IPC specification.
SPARROW_IPC_API void	sparrow_ipc::serialize_schema_message (const sparrow::record_batch &record_batch, any_output_stream &stream)
	Serializes a schema message for a record batch into a byte buffer.