Skip to content

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.