在scala中定义一个函数,参数是RDD类型,调用的时候怎么传入RDD[Int]
时间: 2024-04-29 09:23:02 浏览: 109
Scala基础(8)函数定义
假设要定义一个函数`myFunction`,参数是`RDD`类型:
```scala
def myFunction(rdd: RDD[Int]): Unit = {
// do something
}
```
则调用时可以传入一个`RDD[Int]`类型的变量或常量:
```scala
val myRdd: RDD[Int] = sc.parallelize(Seq(1, 2, 3))
myFunction(myRdd)
```
或者直接传入一个`RDD[Int]`类型的表达式:
```scala
myFunction(sc.parallelize(Seq(1, 2, 3)))
```
阅读全文