Skip to content

Commit 0992aa9

Browse files
committed
#46 Improve Readability of TableRead Impletation
1 parent 1d00d0e commit 0992aa9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pypaimon/py4j/java_implementation.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,7 @@ def __init__(self, j_table_read, j_read_type, catalog_options):
181181
self._j_bytes_reader = get_gateway().jvm.InvocationUtil.createParallelBytesReader(
182182
j_table_read, j_read_type, TableRead._get_max_workers(catalog_options))
183183

184-
def to_arrow(self, splits) -> pa.Table:
184+
def to_arrow(self, splits):
185185
record_batch_reader = self.to_arrow_batch_reader(splits)
186186
return pa.Table.from_batches(record_batch_reader, schema=self._arrow_schema)
187187

0 commit comments

Comments
 (0)