ArroyoSystems / arroyo

Distributed stream processing engine in Rust
https://arroyo.dev
Apache License 2.0
3.81k stars 220 forks source link

Code reuse and function name clashing in UDFs #714

Open hazelnut-99 opened 3 months ago

hazelnut-99 commented 3 months ago

Hi!

Suppose I have two UDFs, UDF_A and UDF_B.

Both have some similar logics, UDF_A: function_1, function_2, function_x (calling function_1 and function_2) UDF_B: function_1, function_2, function_y (calling function_1 and function_2)

If I try to submit the pipeline like this, it will throw an error like 'Local UDFs have duplicate function names'. Considering duplicate function names aren't allowed, is there any better approach for code reuse between different UDFs?

Thanks so much!!!