你好,
我有一些寫下來
數據流的行為描述,上午10點是被記錄是下午10點,表明PySpark流媒體應用程序明顯滯後。的PySpark StreamingListener接口不負責導致滯後;它是用來監測和收集有關流媒體應用程序的進程信息。
的PySpark StreamingListener接口允許您創建自定義偵聽器,可以捕獲事件和相關指標的流媒體應用程序的執行。這可以包括事件像批處理,處理的記錄數量和其他執行統計數據。然而,偵聽器本身不影響流媒體應用程序的時間或行為。
如果你麵臨大幅滯後流媒體應用程序的處理時間,你應該調查的其他方麵你的設置來確定原因。