Skip to content

Commit 8fc0f0f

Browse files
committed
review
1 parent e39c1ab commit 8fc0f0f

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

include/sparrow_ipc/magic_values.hpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,13 +11,13 @@ namespace sparrow_ipc
1111
* Continuation value defined in the Arrow IPC specification:
1212
* https://arrow.apache.org/docs/format/Columnar.html#encapsulated-message-format
1313
*/
14-
constexpr std::array<std::uint8_t, 4> continuation = {0xFF, 0xFF, 0xFF, 0xFF};
14+
inline constexpr std::array<std::uint8_t, 4> continuation = {0xFF, 0xFF, 0xFF, 0xFF};
1515

1616
/**
1717
* End-of-stream marker defined in the Arrow IPC specification:
1818
* https://arrow.apache.org/docs/format/Columnar.html#ipc-streaming-format
1919
*/
20-
constexpr std::array<std::uint8_t, 8> end_of_stream = {0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x00};
20+
inline constexpr std::array<std::uint8_t, 8> end_of_stream = {0xFF, 0xFF, 0xFF, 0xFF, 0x00, 0x00, 0x00, 0x00};
2121

2222
template <std::ranges::input_range R>
2323
[[nodiscard]] bool is_continuation(const R& buf)

include/sparrow_ipc/serialize.hpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ namespace sparrow_ipc
5151
);
5252
}
5353
std::vector<uint8_t> serialized_schema = serialize_schema_message(record_batches[0]);
54-
std::vector<uint8_t> serialized_record_batches = serialize_record_batches(record_batches);
54+
std::vector<uint8_t> serialized_record_batches = serialize_record_batches_without_schema_message(record_batches);
5555
serialized_schema.insert(
5656
serialized_schema.end(),
5757
std::make_move_iterator(serialized_record_batches.begin()),

include/sparrow_ipc/serialize_utils.hpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ namespace sparrow_ipc
6464
* @note The function uses move iterators to efficiently transfer the serialized data
6565
* from individual record batches to the output vector.
6666
*/
67-
[[nodiscard]] std::vector<uint8_t> serialize_record_batches(const R& record_batches)
67+
[[nodiscard]] std::vector<uint8_t> serialize_record_batches_without_schema_message(const R& record_batches)
6868
{
6969
std::vector<uint8_t> output;
7070
for (const auto& record_batch : record_batches)

0 commit comments

Comments
 (0)