BasicOperators Execution Planning Strategy¶
BasicOperators is an execution planning strategy for basic conversions of logical operators to their physical representatives.
Conversions¶
| Logical Operator | Physical Operator |
|---|---|
| DataWritingCommand | DataWritingCommandExec |
| RunnableCommand | ExecutedCommandExec |
| MemoryPlan (Spark Structured Streaming) | LocalTableScanExec |
| DeserializeToObject | DeserializeToObjectExec |
| FlatMapGroupsWithState | CoGroupExec or MapGroupsExec |
| ... | ... |
| CollectMetrics | CollectMetricsExec |
Tip
Refer to the source code of BasicOperators to confirm the most up-to-date operator mapping.