Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
None
-
None
-
None
Description
Currently there exists some projects like Pig On Storm, SQL on storm (Squall, SQLstream) that can query over streaming data, but for Spark Streaming, it is a blank area. It will be a good feature to add streaming supported SQL to Spark SQL.
From semantic perspective, DStream is quite alike RDD, they both have join, filter, groupBy operators and so on, also DStream is backed by RDD, so it is transplant-able and reusable from existing spark plan.
Also Catalyst has a clear division for each step, we can fully use its parse and logical plan analysis steps, with only different physical plan.
So here we propose to add streaming support in Catalyst.
Attachments
Attachments
Issue Links
- duplicates
-
SPARK-8360 Structured Streaming (aka Streaming DataFrames)
- Resolved