ContinuousExecutionRelation Leaf Logical Operator¶
ContinuousExecutionRelation is a MultiInstanceRelation (Spark SQL) leaf logical operator.
Tip
Learn more about Leaf Logical Operators in The Internals of Spark SQL book.
Creating Instance¶
ContinuousExecutionRelation takes the following to be created:
- [[source]] ContinuousReadSupport source
- [[extraOptions]] Options (
Map[String, String]) - [[output]] Output attributes (
Seq[Attribute]) - [[session]]
SparkSession(Spark SQL)
ContinuousExecutionRelation is created (to represent StreamingRelationV2 with ContinuousReadSupport data source) when ContinuousExecution is created (and requested for the logical plan).