[python] Fix flake8 E501 in table_query_auth_test predicate literals

Author: MgjLLL

paimon-python/pypaimon/read/table_read.py

@@ -111,6 +111,9 @@ def _record_generator():
                 reader = self._create_reader_for_split(split)
                 try:
                     if isinstance(reader, RecordBatchReader):
+                        blob_indices = getattr(reader, 'blob_field_indices', None)
+                        vector_indices = getattr(reader, 'vector_field_indices', None)
+                        file_io = self.table.file_io
                         for arrow_batch in iter(reader.read_arrow_batch, None):
                             has_rk = ROW_KIND_COLUMN in arrow_batch.schema.names
                             if has_rk:
@@ -123,7 +126,11 @@ def _record_generator():
                                     arrow_batch.column(j)[row_idx].as_py()
                                     for j in data_cols
                                 )
-                                row = OffsetRow(row_tuple, 0, len(data_cols))
+                                row = OffsetRow(
+                                    row_tuple, 0, len(data_cols),
+                                    file_io=file_io,
+                                    blob_field_indices=blob_indices,
+                                    vector_field_indices=vector_indices)
                                 if has_rk:
                                     kind_str = arrow_batch.column(rk_idx)[row_idx].as_py()
                                     row.set_row_kind_byte(RowKind.from_string(kind_str).value)

paimon-python/pypaimon/tests/table_query_auth_test.py

@@ -310,8 +310,12 @@ def test_convert_plan_preserves_snapshot_id(self):
 
         split = MagicMock()
         original_plan = Plan([split], snapshot_id=42)
+        predicate_json = (
+            '{"kind":"LEAF","transform":{"name":"FIELD_REF",'
+            '"fieldRef":{"name":"id"}},"function":"EQUAL","literals":[1]}'
+        )
         auth_result = TableQueryAuthResult(
-            filter=['{"kind":"LEAF","transform":{"name":"FIELD_REF","fieldRef":{"name":"id"}},"function":"EQUAL","literals":[1]}'],
+            filter=[predicate_json],
             column_masking=None)
         converted = auth_result.convert_plan(original_plan)
         assert converted.snapshot_id == 42
@@ -323,8 +327,12 @@ def test_convert_plan_preserves_none_snapshot_id(self):
 
         split = MagicMock()
         original_plan = Plan([split], snapshot_id=None)
+        predicate_json = (
+            '{"kind":"LEAF","transform":{"name":"FIELD_REF",'
+            '"fieldRef":{"name":"id"}},"function":"EQUAL","literals":[1]}'
+        )
         auth_result = TableQueryAuthResult(
-            filter=['{"kind":"LEAF","transform":{"name":"FIELD_REF","fieldRef":{"name":"id"}},"function":"EQUAL","literals":[1]}'],
+            filter=[predicate_json],
             column_masking=None)
         converted = auth_result.convert_plan(original_plan)
         assert converted.snapshot_id is None