def readJsonResource(file: String): List[String] = {
  val stream = getClass.getResourceAsStream(file)
  scala.io.Source.fromInputStream(stream)
    .getLines
    .toList
}

然后对返回的List做遍历处理。也还可以将List转变为RDD和Dataset。

本站所有内容均为原创,本站保留所有权利。在保留原始来源链接的情况下,允许非商业用途的转载。拒绝一切商业性转载。

picture loss