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).