Since many anomaly detection algorithms are implemented in Python, it would be nice to be able to use them as regular operators from our JVM Flink environment. Unfortunately, this is a feature that's still in development by the Flink community. FLIP-130 and FLINK-18761 track the progress of the stateless DataStream implementation for PyFlink. The stateful implementation will come later. This issue will remain on hold until those implementations are complete, since it would be pointless and very difficult to reimplement the work they're already doing in the meantime.
Since many anomaly detection algorithms are implemented in Python, it would be nice to be able to use them as regular operators from our JVM Flink environment. Unfortunately, this is a feature that's still in development by the Flink community. FLIP-130 and FLINK-18761 track the progress of the stateless DataStream implementation for PyFlink. The stateful implementation will come later. This issue will remain on hold until those implementations are complete, since it would be pointless and very difficult to reimplement the work they're already doing in the meantime.