StreamingQuery.awaitTermination((超时))
|
等待终止这查询,通过query.stop ()或者是一个例外。 |
StreamingQuery.exception()
|
-
返回
-
|
StreamingQuery.explain((扩展))
|
打印到控制台(逻辑和物理)计划用于调试目的。 |
StreamingQuery.id
|
返回这个查询的惟一id从检查点数据之间的重启。 |
StreamingQuery.isActive
|
是否这个流查询目前活跃。 |
StreamingQuery.lastProgress
|
返回最近的StreamingQueryProgress更新这个流的查询或没有如果没有更新进展 |
StreamingQuery.name
|
返回指定的名称查询,如果未指定或null。 |
StreamingQuery.processAllAvailable()
|
直到所有可用的数据块在源已经处理并致力于水槽。 |
StreamingQuery.recentProgress
|
返回一个数组最近的[[StreamingQueryProgress]]更新查询。 |
StreamingQuery.runId
|
返回这个查询的惟一的id在重启时不存在。 |
StreamingQuery.status
|
返回当前状态的查询。 |
StreamingQuery.stop()
|
停止这种流查询。 |
StreamingQueryManager.active
|
返回一个列表的活跃与此SQLContext相关查询 |
StreamingQueryManager.addListener(听众)
|
注册一个StreamingQueryListener接收返回值的生命周期事件StreamingQuery。 |
StreamingQueryManager.awaitAnyTermination([…])
|
等到任何的查询相关SQLContext终止自创建上下文,或自resetTerminated ()被称为。 |
StreamingQueryManager.get(id)
|
返回一个活跃的查询从这个SQLContext或抛出异常活跃的查询与这个名字并不存在。 |
StreamingQueryManager.removeListener(听众)
|
取消注册StreamingQueryListener。 |
StreamingQueryManager.resetTerminated()
|
忘记过去的终止,以便查询awaitAnyTermination ()可以再次等待新终端使用。 |