BroadcastExchangeLike Physical Operators¶

BroadcastExchangeLike is an extension of the Exchange abstraction for physical operators that...FIXME

Contract¶

completionFuture¶

completionFuture: Future[Broadcast[Any]]

Used when:

• BroadcastQueryStageExec physical operator is requested to materializeWithTimeout

relationFuture¶

relationFuture: Future[Broadcast[Any]]

Used when:

• AQEPropagateEmptyRelation adaptive logical optimization is executed
• BroadcastQueryStageExec physical optimization is requested to cancel

runId¶

runId: UUID

Job group ID (for cancellation)

Used when:

• BroadcastQueryStageExec physical operator is requested to cancel
• BroadcastExchangeExec physical operator is requested for the relationFuture and doExecuteBroadcast

Runtime Statistics¶

runtimeStatistics: Statistics

Statistics with data size and row count

See:

• BroadcastExchangeExec

Used when:

• BroadcastQueryStageExec physical operator is requested for runtime statistics

Implementations¶

• BroadcastExchangeExec