(fluss-rust) branch main updated: Support FixedSizeBinary in python (#538)

[ab...@apache.org]

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

fresh-borzoni pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss-rust.git


The following commit(s) were added to refs/heads/main by this push:
     new 90d7f724 Support FixedSizeBinary in python (#538)
90d7f724 is described below

commit 90d7f724135725df8a7828f1b55545992e63affc
Author: Kaiqi Dong <ka...@bitvavo.com>
AuthorDate: Sat May 9 22:46:53 2026 +0200

    Support FixedSizeBinary in python (#538)
---
 bindings/python/src/utils.rs                 | 1 +
 bindings/python/test/test_kv_table.py        | 3 +++
 website/docs/user-guide/python/data-types.md | 1 +
 3 files changed, 5 insertions(+)

diff --git a/bindings/python/src/utils.rs b/bindings/python/src/utils.rs
index 5efcf5e7..e0771397 100644
--- a/bindings/python/src/utils.rs
+++ b/bindings/python/src/utils.rs
@@ -57,6 +57,7 @@ impl Utils {
             ArrowDataType::Float64 => DataTypes::double(),
             ArrowDataType::Utf8 | ArrowDataType::LargeUtf8 => DataTypes::string(),
             ArrowDataType::Binary | ArrowDataType::LargeBinary => DataTypes::bytes(),
+            ArrowDataType::FixedSizeBinary(n) => DataTypes::binary(*n as usize),
             ArrowDataType::Date32 => DataTypes::date(),
             ArrowDataType::Date64 => DataTypes::date(),
             ArrowDataType::Time32(unit) => match unit {
diff --git a/bindings/python/test/test_kv_table.py b/bindings/python/test/test_kv_table.py
index 36aa3e46..39407375 100644
--- a/bindings/python/test/test_kv_table.py
+++ b/bindings/python/test/test_kv_table.py
@@ -358,6 +358,7 @@ async def test_all_supported_datatypes(connection, admin):
                 pa.field("col_timestamp_ntz", pa.timestamp("us")),
                 pa.field("col_timestamp_ltz", pa.timestamp("us", tz="UTC")),
                 pa.field("col_bytes", pa.binary()),
+                pa.field("col_binary", pa.binary(16)),
             ]
         ),
         primary_keys=["pk_int"],
@@ -385,6 +386,7 @@ async def test_all_supported_datatypes(connection, admin):
         "col_timestamp_ntz": datetime(2026, 1, 23, 10, 13, 47, 123000),
         "col_timestamp_ltz": datetime(2026, 1, 23, 10, 13, 47, 123000),
         "col_bytes": b"binary data",
+        "col_binary": b"binary_data_0123",
     }
 
     handle = upsert_writer.upsert(row_data)
@@ -411,6 +413,7 @@ async def test_all_supported_datatypes(connection, admin):
         2026, 1, 23, 10, 13, 47, 123000, tzinfo=timezone.utc
     )
     assert result["col_bytes"] == b"binary data"
+    assert result["col_binary"] == b"binary_data_0123"
 
     # Test with null values for all nullable columns
     null_row = {"pk_int": 2}
diff --git a/website/docs/user-guide/python/data-types.md b/website/docs/user-guide/python/data-types.md
index 99677038..8e4371e2 100644
--- a/website/docs/user-guide/python/data-types.md
+++ b/website/docs/user-guide/python/data-types.md
@@ -12,6 +12,7 @@ The Python client uses PyArrow types for schema definitions:
 | `pa.float32()` / `float64()`                    | Float / Double                    | `float`             |
 | `pa.string()`                                   | String                            | `str`               |
 | `pa.binary()`                                   | Bytes                             | `bytes`             |
+| `pa.binary(n)`                                  | Binary(n)                         | `bytes`             |
 | `pa.date32()`                                   | Date                              | `datetime.date`     |
 | `pa.time32("ms")`                               | Time                              | `datetime.time`     |
 | `pa.timestamp("us")`                            | Timestamp (NTZ)                   | `datetime.datetime` |