pyspark.sql.streaming.StreamingQueryManager.get¶
-
StreamingQueryManager。得到( id:str )→pyspark.sql.streaming.query.StreamingQuery¶ -
返回一個活躍的查詢從這個SQLContext或拋出異常活躍的查詢與這個名字並不存在。
例子
> > >平方=自衛隊。writeStream。格式(“記憶”)。queryName(“this_query”)。開始()> > >平方。的名字“this_query”> > >平方=火花。流。得到(平方。id)> > >平方。isActive真正的> > >平方=sqlContext。流。得到(平方。id)> > >平方。isActive真正的> > >平方。停止()