Spark Streaming SQL是什么？

Spark Streaming SQL 在 Spark Structured Streaming 之上提供了 SQL 能力， 降低了实时业务开发的门槛，使得离线业务实时化更简单方便。

Spark Streaming SQL 支持的语法如下：

下面以实时消费 SLS 为例：

# 创建 loghub 源表
spark-sql> CREATE TABLE loghub_intput_tbl(content string)
> USING loghub
> OPTIONS
> (...)
# 创建 delta 目标表
spark-sql> CREATE TABLE delta_output_tbl(content string)
> USING delta
> OPTIONS
> (...);
# 创建流式 SCAN
spark-sql> CREATE SCAN loghub_table_intput_test_stream
> ON loghub_intput_tbl
> USING STREAM;
# 将 loghub 源表数据插入 delta 目标表
spark-sql> INSERT INTO delta_output_tbl SELECT content FROM loghub_table_i
ntput_test_stream;