Skip to content

Commit 2ba0b9a

Browse files
committed
Resolve error on registering udaf #874
1 parent 47b2c8b commit 2ba0b9a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/datafusion/udf.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ def __init__(
192192
See :py:func:`udaf` for a convenience function and argument
193193
descriptions.
194194
"""
195-
self._udf = df_internal.AggregateUDF(
195+
self._udaf = df_internal.AggregateUDF(
196196
name, accumulator, input_types, return_type, state_type, str(volatility)
197197
)
198198

@@ -203,7 +203,7 @@ def __call__(self, *args: Expr) -> Expr:
203203
occur during the evaluation of the dataframe.
204204
"""
205205
args = [arg.expr for arg in args]
206-
return Expr(self._udf.__call__(*args))
206+
return Expr(self._udaf.__call__(*args))
207207

208208
@staticmethod
209209
def udaf(

0 commit comments

Comments
 (0)