Spark的任务是什么？Spark工作人员如何执行jar文件？

在http://spark.apache.org/docs/0.8.0/cluster-overview.html上阅读了一些文档后,我得到了一些我想澄清的问题.

以Spark为例:

JavaSparkContext spark = new JavaSparkContext(
  new SparkConf().setJars("...").setSparkHome....);
JavaRDD file = spark.textFile("hdfs://...");

// step1
JavaRDD words =
  file.flatMap(new FlatMapFunction() {
    public Iterable call(String s) {
      return Arrays.asList(s.split(" "));
    }
  });

// step2
JavaPairRDD pairs =
  words.map(new PairFunction() {
    public Tuple2 call(String s) {
      return new Tuple2(s, 1);
    }
  });

// step3
JavaPairRDD counts =
  pairs.reduceByKey(new Function2() {
    public Integer call(Integer a, Integer b) {
      return a + b;
    }
  });

counts.saveAsTextFile("hdfs://...");

因此,假设我有3个节点集群,节点1作为主节点运行,并且上面的驱动程序已被正确判断(比如application-test.jar).所以现在我在主节点上运行此代码,我相信在SparkContext创建之后,application-test.jar文件将被复制到工作节点(并且每个工作人员将为该应用程序创建一个目录).

那么现在我的问题是:示例任务中的step1,step2和step3是否会被发送给工作人员？如果是,那么工人如何执行呢？喜欢java -cp "application-test.jar" step1等等？