Skip to content

Commit e3a23d8

Browse files
committed
feat(PartitionedOutput): Add PrestoIterativePartitioningSerializer
This commit introduces PrestoIterativePartitioningSerializer, which buffers RowVectors across multiple append() calls, partitions rows in-place using PartitionedVector, and on flush() serializes each non-empty partition into a Presto wire-format IOBuf. The serializer has no dependency on velox_exec: it returns raw folly::IOBuf objects, leaving SerializedPage creation to the caller.
1 parent 70c3fd8 commit e3a23d8

7 files changed

Lines changed: 1751 additions & 0 deletions

velox/serializers/CMakeLists.txt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ velox_add_library(
2929
UnsafeRowSerializer.cpp
3030
PrestoBatchVectorSerializer.cpp
3131
PrestoHeader.cpp
32+
PrestoIterativePartitioningSerializer.cpp
3233
PrestoIterativeVectorSerializer.cpp
3334
PrestoSerializerDeserializationUtils.cpp
3435
PrestoSerializerEstimationUtils.cpp

0 commit comments

Comments
 (0)