You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2026/05/26 05:34:25 UTC

(paimon) branch vector_python_dedicated created (now 67ad46638a)

This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a change to branch vector_python_dedicated
in repository https://gitbox.apache.org/repos/asf/paimon.git


      at 67ad46638a [python] Support vortex format in vector writer

This branch includes the following new commits:

     new 67ad46638a [python] Support vortex format in vector writer

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



(paimon) 01/01: [python] Support vortex format in vector writer

Posted by lz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a commit to branch vector_python_dedicated
in repository https://gitbox.apache.org/repos/asf/paimon.git

commit 67ad46638a6a3de8e706b14702187828427f471b
Author: JingsongLi <ji...@gmail.com>
AuthorDate: Tue May 26 13:34:04 2026 +0800

    [python] Support vortex format in vector writer
    
    Co-Authored-By: Claude Opus 4.6 <no...@anthropic.com>
---
 paimon-python/pypaimon/write/writer/vector_writer.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/paimon-python/pypaimon/write/writer/vector_writer.py b/paimon-python/pypaimon/write/writer/vector_writer.py
index e3becd86d9..b51e2e49ae 100644
--- a/paimon-python/pypaimon/write/writer/vector_writer.py
+++ b/paimon-python/pypaimon/write/writer/vector_writer.py
@@ -64,6 +64,8 @@ class VectorWriter(AppendOnlyDataWriter):
             self.file_io.write_parquet(file_path, data,
                                        compression=self.compression,
                                        zstd_level=self.zstd_level)
+        elif self.vector_file_format == CoreOptions.FILE_FORMAT_VORTEX:
+            self.file_io.write_vortex(file_path, data)
         else:
             raise ValueError(f"Unsupported vector file format: {self.vector_file_format}")