gistfile1.scala

import org.rogach.scallop._
import java.io.{Serializable, ByteArrayOutputStream, ByteArrayInputStream, ObjectOutputStream, ObjectInputStream}

val args = Array("--apples", "33")

private class ConfSerializationProxy(@transient private var orig: Conf) extends Serializable {
  private def writeObject(out: ObjectOutputStream) {
    out.defaultWriteObject()
    out.writeObject(orig.args.toArray)
  }
  private def readObject(in: ObjectInputStream) {
    in.defaultReadObject()
    orig = new Conf(in.readObject().asInstanceOf[Array[String]].toList)
  }
  private def readResolve(): AnyRef = orig
}

class Conf(arguments: Seq[String]) extends org.rogach.scallop.ScallopConf(arguments) with Serializable {
  val apples = opt[Int](required = true)
  verify()
  protected final def writeReplace(): AnyRef = new ConfSerializationProxy(this)
}

val conf = new Conf(args)
sc.parallelize(Seq(1,2,3)).map { i =>
  println(s"$i: " + conf.apples() + " apples")
}