Structured Streaming编程模型
编程模型●编程模型概述一个流的数据源从逻辑上来说就是一个不断增长的动态表格,随着时间的推移,新数据被持续不断地添加到表格的末尾。用户可以使用Dataset/DataFrame函数式API或者SQL来对这个动态数据源进行实时查询。每次查询在逻辑上就是对当前的表格内容执行一次SQL查询。什么时候执行查询则是由用户通过触发器(Trigger)来设定时间(毫秒级)。...