Repository navigation
Pass control messages to Python UDF operator in Amber #816
Description
The new Amber engine supports many types of control messages, such as pause, resume, breakpoints, etc.. Such control messages are detected by the engine after every tuple iteration.
In the Python UDF operator implementation, such checks happen at every batch. This will make response to control messages slow. We want to pass control messages to the Python UDF operator.
Activity