pyspark.sql.streaming.StreamingQueryManager.get

StreamingQueryManager. 获取 高山市 标识符:字符串 )→ pyspark.sql.streaming.query.StreamingQuery

SQLContext返回主动查询或except

实例

>>>sq=sdf.写Stream.格式化高山市记忆性).查询Name高山市........).启动(b)>>>sq.名称........>>>sq=点火.溪流.获取高山市sq.标识符)>>>sq.sActionive系统真实性>>>sq=sqlcontext.溪流.获取高山市sq.标识符)>>>sq.sActionive系统真实性>>>sq.停止(b)

前一

pyspark.sql.streaming.StreamingQueryManager.awaitAnyTermination

下一个

pyspark.sql.streaming.StreamingQueryManager.removeListener