val textFileRdd = sc.textFile("hdfs://192.168.0.100:9000/test/1.txt") textFileRdd.map(line => line.toInt) textFileRdd.foreach(println(_))