xpark.dataset.expressions.ExprUDFOptions
-
class xpark.dataset.expressions.ExprUDFOptions[source]
Attributes
-
batch_size: Literal['default'] | int | None
-
num_workers: dict[Literal['CPU', 'GPU', 'IO'], tuple[int, int] | int] | None
-
worker_ray_remote_args: dict[Literal['CPU', 'GPU', 'IO'], dict] | None