package testScala
import testScala.Team
object printTest {
def test(spark: SparkSession): Unit = {
val teamArr = spark.SparkContext.parallelize(Range(1, 10))
val teamArr2 = teamArr.map(id => {
val team = new Team
team.setId(id)
team
})
teamArr2.foreach(team => println("id:" + team.getId))
println()
}
}
| package testScala import testScala.Team object printTest { def test(spark: Array[String]): Unit = { val team1 = new Team team1.setId(10) val teamArr = Range(1, 10) val teamArr2 = teamArr.map(id => { val team = new Team team.setId(id) team }) teamArr2.foreach(team => println("id:" + team.getId)) println() } } |
