pyspark.sql.streaming.StreamingQueryManager???
-
类
pyspark.sql.streaming.StreamingQueryManager高山市 sqm:py4j.java_gateway.JavaObject ) ??? -
类管理全部
流动查询流查询活动注解
API正在演化
方法论
添加倾听器听者寄存器
StreamingQueryListener接收生命周期事件调用流动查询.awaitAnyTermination([定时])等待相关SQLCortext自上下文创建或自上下文创建
resetTerminated()被调用获取i)SQLContext返回主动查询或except
删除监听器听者Deregistera系统
StreamingQueryListener.重置定时(b)忘记过去终止查询
awaitAnyTermination()可再次使用等待新解析属性化
返回主动查询列表