StructuredStreaming基础操作和窗口操作

一、流式DataFrames/Datasets的结构类型推断与划分 　　◆ 默认情况下，基于文件源的结构化流要求必须指定schema，这种限制确保即 　　使在失败的情况下也会使用一致的模式来进行流查询。 　　◆ 对于特殊用例，可以通过设置spark.sql.streaming.schemaInference = true。 　　此时将会开启Spark自动类型推断功能。 　　◆ 注意：默认Spark

>>阅读原文<<