Skip to content

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:

Logical Resolution

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