Class BreakingChangeInfo

Object
org.apache.spark.BreakingChangeInfo
All Implemented Interfaces:
Serializable, scala.Equals, scala.Product

public class BreakingChangeInfo extends Object implements scala.Product, Serializable
Additional information if the error was caused by a breaking change.

param: migrationMessage A message explaining how the user can migrate their job to work with the breaking change. param: mitigationConfig A spark config flag that can be used to mitigate the breaking change. param: needsAudit If true, the breaking change should be inspected manually. If false, the spark job should be retried by setting the mitigationConfig.

See Also:
  • Constructor Details

    • BreakingChangeInfo

      public BreakingChangeInfo(scala.collection.immutable.Seq<String> migrationMessage, scala.Option<MitigationConfig> mitigationConfig, boolean needsAudit)
  • Method Details

    • apply

      public abstract static R apply(T1 v1, T2 v2, T3 v3)
    • toString

      public static String toString()
    • migrationMessage

      public scala.collection.immutable.Seq<String> migrationMessage()
    • mitigationConfig

      public scala.Option<MitigationConfig> mitigationConfig()
    • needsAudit

      public boolean needsAudit()