Skip to content

Commit 43084fa

Browse files
committed
fix(datafusion): bring back UDF registration
1 parent 669b352 commit 43084fa

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

ibis/backends/datafusion/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -474,6 +474,7 @@ def to_pyarrow_batches(
474474
) -> pa.ipc.RecordBatchReader:
475475
pa = self._import_pyarrow()
476476

477+
self._register_udfs(expr)
477478
self._register_in_memory_tables(expr)
478479

479480
sql = self.compile(expr.as_table(), params=params, **kwargs)

0 commit comments

Comments
 (0)