package org.apache.spark.sql.catalyst.plans.physical

trait BroadcastMode {
  def canonicalized: BroadcastMode
  def transform(rows: Array[InternalRow]): Any
  def transform(rows: Iterator[InternalRow], sizeHint: Option[Long]): Any
}