WriteToContinuousDataSource Unary Logical Operator
WriteToContinuousDataSource is a unary logical operator (LogicalPlan) that is created exclusively 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).
|
Tip
|
Read up on DataSourceV2Strategy Execution Planning Strategy in The Internals of Spark SQL book. |
WriteToContinuousDataSource takes the following to be created:
WriteToContinuousDataSource uses empty output schema (which is exactly to say that no output is expected whatsoever).