StreamingQueryManager。
活躍的
返回一個列表的活躍與此SQLContext相關查詢
例子
> > >平方=自衛隊。writeStream。格式(“記憶”)。queryName(“this_query”)。開始()> > >平方米=火花。流> > >#活動流查詢的列表> > >(問。的名字為問在平方米。活躍的](“this_query”)> > >平方。停止()
以前的
pyspark.sql.streaming.StreamingQuery.stop
下一個
pyspark.sql.streaming.StreamingQueryManager.addListener