介绍 QStreaming是一个框架，可简化基于ETL的编写和执行 它基于简单的类似于SQL的配置文件，并且可以在任何Spark集群上运行 入门 构型 要运行QStreaming，必须首先定义如下的Pipeline DSL文件。 管道DSL 例如，一个简单的管道dsl文件应如下所示： -- DDL for streaming input which connect to a kafka topic -- this declares five fields based on the JSON d