def readJsonResource(file: String): List[String] = {
val stream = getClass.getResourceAsStream(file)
scala.io.Source.fromInputStream(stream)
.getLines
.toList
}
然后对返回的List做遍历处理。也还可以将List转变为RDD和Dataset。
def readJsonResource(file: String): List[String] = {
val stream = getClass.getResourceAsStream(file)
scala.io.Source.fromInputStream(stream)
.getLines
.toList
}
然后对返回的List做遍历处理。也还可以将List转变为RDD和Dataset。