object PCA {
  def main(args: Array[String]) {
    val conf = new SparkConf()                                     //创建环境变量
      .setMaster("local")                                             //设置本地化处理
      .setAppName("PCA ")                                       //设定名称
    val sc = new SparkContext(conf)                                 //创建环境变量实例

    val data = sc.textFile("c://a.txt")                                   //创建RDD文件路径
      .map(_.split(' ')                                               //按“ ”分割
      .map(_.toDouble))                                            //转成Double类型
      .map(line => Vectors.dense(line))                               //转成Vector格式
    val rm = new RowMatrix(data)                                    //读入行矩阵

    val pc = rm.computePrincipalComponents(3)     //提取主成分，设置主成分个数
    val mx = rm.multiply(pc)         //创建主成分矩阵
    mx.rows.foreach(println)         //打印结果
  }
}

a.txt格式如下：

1 2 3 4 
5 6 7 8
0 9 8 7
6 4 2 1