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.