在异常或终止时重新启动 Spark 结构化流查询

Pri*_*ava 6 apache-spark spark-structured-streaming

以编程方式重新启动因异常而终止的结构化流查询的正确方法是什么?示例代码或参考将不胜感激。

可以在类的onQueryTerminated()事件处理程序中完成StreamingQueryListener吗?