結構化流

結構化流是Apache Spark API，它使您可以以相同的方式在流數據上表達計算，就像在靜態數據上表達批處理計算一樣。結構化流動引擎會逐步執行計算，並連續更新流數據到達時的結果。有關結構化流的概述，請參閱Apache Spark結構化流程編程指南。這些文章提供了介紹性筆記本，有關如何使用特定類型的流源和水槽的詳細信息，如何將流媒體放入生產中，以及注冊的筆記本，展示了示例用例：