WriteToStreamStatement Logical Operator¶

WriteToStreamStatement is a unary logical operator (Spark SQL).

Creating Instance¶

WriteToStreamStatement takes the following to be created:

• User-specified Name
• Checkpoint Location
• useTempCheckpointLocation flag
• recoverFromCheckpointLocation flag
• Sink Table (Spark SQL)
• OutputMode
• Hadoop Configuration
• isContinuousTrigger flag
• LogicalPlan (Spark SQL) of the Input Query
• Optional TableCatalog and Identifier (default: undefined)

WriteToStreamStatement is created when:

• StreamingQueryManager is requested to create a streaming query

Logical Resolution¶

WriteToStreamStatement is resolved to WriteToStream operator using ResolveWriteToStream logical resolution rule.