Something like this? sparkSession.experimental.extraStrategies = Seq(Strategy)
val logicalPlan = df.logicalPlan val newPlan: LogicalPlan = Strategy(logicalPlan) Dataset.ofRows(sparkSession, newPlan) On Thu, Mar 1, 2018 at 8:20 PM, Keith Chapman <keithgchap...@gmail.com> wrote: > Hi, > > I'd like to write a custom Spark strategy that runs after all the existing > Spark strategies are run. Looking through the Spark code it seems like the > custom strategies are prepended to the list of strategies in Spark. Is > there a way I could get it to run last? > > Regards, > Keith. > > http://keith-chapman.com >
