尝试将文本文件传递到函数中,以便在scala中执行某些操作,但我不知道如何将其传递到函数中。
我想通过它,因为我有多个文本文件和所做的工作是相当紧张
object SimpleApp {
def main(args: Array[String]) {
val conf = new SparkConf().setAppName("Simple Application")
val sc = new SparkContext(conf)
val books = sc.textFile(
"hdfs://quickstart.cloudera:8020/user/cloudera/books/books2/*"
)
checkLang(books)
}
def checkLang (books: textFile) = {
//do sonething
}
1条答案
按热度按时间g6ll5ycj1#