使用 spark scala 读取每一行的第二个单词

【问题标题】：reading second word of every line using spark scala使用 spark scala 读取每一行的第二个单词
【发布时间】：2019-07-12 13:18:06
【问题描述】：

我想读取/打印每一行的第二个单词。

输入->>人并没有看上去那么美，
当他们走路或说话时。
他们只有爱的时候才会美丽，
因为他们关心他们分享。

输出->> 是他们是他们

【问题讨论】：

您好，如果您发布特定问题和您尝试过的内容，您可能会得到更好的回复。请查看stackoverflow.com/help/how-to-ask 获取提示。

标签： scala apache-spark

【解决方案1】：

请检查：

    val myDF=spark.read.text("<path>")
    import org.apache.spark.sql._
    import org.apache.spark.sql.types._
    val rdd=myDF.rdd.map(_.mkString("")).map(f=> Row(f.split(" ")(1)))
    val schema:StructType  = (new StructType).add("values",StringType )
    val result=spark.createDataFrame(rdd, schema)
    result.show()

【讨论】：