MCPcopy
hub / github.com/pathwaycom/pathway / udf

Function udf

python/pathway/internals/udfs/__init__.py:299–307  ·  view source on GitHub ↗
(
    *,
    return_type: Any = None,
    deterministic: bool = False,
    propagate_none: bool = False,
    executor: Executor = AutoExecutor(),
    cache_strategy: CacheStrategy | None = None,
    max_batch_size: int | None = None,
)

Source from the content-addressed store, hash-verified

297
298@overload
299def udf(
300 *,
301 return_type: Any = None,
302 deterministic: bool = False,
303 propagate_none: bool = False,
304 executor: Executor = AutoExecutor(),
305 cache_strategy: CacheStrategy | None = None,
306 max_batch_size: int | None = None,
307) -> Callable[[Callable], UDF]: ...
308
309
310@overload

Callers 4

applyFunction · 0.90
apply_with_typeFunction · 0.90
apply_asyncFunction · 0.90
_write_single_row_listFunction · 0.85

Calls 2

AutoExecutorClass · 0.90
UDFFunctionClass · 0.85

Tested by 1

_write_single_row_listFunction · 0.68