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 ()可以再次等待新終端使用。 |