BroadcastModes¶
BroadcastMode is an abstraction of broadcast modes that can transform internal rows (with optional size hint).
BroadcastMode is used to create:
- BroadcastDistribution
- BroadcastPartitioning
- BroadcastExchangeExec physical operator
Contract¶
Canonicalized Form¶
canonicalized: BroadcastMode
Transforming InternalRows into HashedRelation (with Optional Size Hint)¶
transform(
rows: Iterator[InternalRow],
sizeHint: Option[Long]): Any
Used when:
BroadcastExchangeExecphysical operator is requested for relationFuture
Transform Rows¶
transform(
rows: Array[InternalRow]): Any
Note
transform(rows) does not seem to be used.
Implementations¶
- HashedRelationBroadcastMode
IdentityBroadcastMode