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