import com.dongjinlee.spark.konlp.functions._
import com.dongjinlee.spark.konlp.types._
import org.apache.spark.sql.functions._

...

// 입력 문자열
val lines = """바람이 살짝 잠을 깨운 꽃잎에
        |좋아해 이 말 한마디를 담아서
        |어젯밤 꼬박 새운 나의 노래에
        |사랑의 마법을 걸어보네""".stripMargin.split('\n').toSeq

// 형태소 분석
val df = lines.toDF("str")
  .withColumn("morphemes", explode(morphemes(col("str"))))
  .withColumn("surface", col("morphemes.surface"))
  .withColumn("pos_id", col("morphemes.pos_id"))
  .select(col("surface"), col("pos_id"))

df.show

// +-------+------+
// |surface|pos_id|
// +-------+------+
// |  바람  |   0  |
// |   이  |  15  |
// |  살짝  |  12  |
// |   잠  |   0  |
// |   을  |  18  |
// |  깨우  |   6  |
// |   ㄴ  |  28  |
// ...
// +-------+------+

// 입력 문자열
val text = """13인의 아해가 도로로 질주하오.
       |길은 막다른 골목이 적당하오.
       |
       |제 1의 아해가 무섭다고 그리오.""".stripMargin.replaceAll("\\n", " ")

// 문장 단위 분할
val df = Seq(text).toDF("str")
  .withColumn("sentence", explode(ssplit(col("str"))))
  .select(col("sentence"))

df.printSchema

// root
//  |-- sentence: string (nullable = false)s 8s

df.show

// +------------------------------+
// |           sentence           |
// +------------------------------+
// |   13인의 아해가 도로로 질주하오.  |
// |    길은 막다른 골목이 적당하오.   |
// |   제 1의 아해가 무섭다고 그리오.  |
// +------------------------------+