Skip to content

CustomShuffleReaderRule Physical Optimization Rules

CustomShuffleReaderRule is an extension of the Rule abstraction for physical optimization rules (Rule[SparkPlan]) that supportedShuffleOrigins.

Contract

supportedShuffleOrigins

supportedShuffleOrigins: Seq[ShuffleOrigin]

Used when:

  • AdaptiveSparkPlanExec physical operator is requested for the final physical query plan
  • others (FIXME: perhaps not as important?)

Implementations


Last update: 2021-05-17