Skip to content

WriteToContinuousDataSource Unary Logical Operator

WriteToContinuousDataSource is a unary logical operator (LogicalPlan) that is created when ContinuousExecution is requested to run a streaming query in continuous mode (to create an IncrementalExecution).

WriteToContinuousDataSource is planned (translated) to a WriteToContinuousDataSourceExec unary physical operator (when DataSourceV2Strategy execution planning strategy is requested to plan a logical query).

[[output]] WriteToContinuousDataSource uses empty output schema (which is exactly to say that no output is expected whatsoever).

Creating Instance

WriteToContinuousDataSource takes the following to be created:

  • [[query]] Child logical operator (LogicalPlan)