[ https://issues.apache.org/jira/browse/SPARK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sean Owen resolved SPARK-12863. ------------------------------- Resolution: Not A Problem You haven't proposed an API; you're asking how to do something, which can already be done. At best you're asking for some different API. Please start on user@ and do not reopen this. > missing api for renaming and mapping result of operations on GroupedDataset > to case classes > ------------------------------------------------------------------------------------------- > > Key: SPARK-12863 > URL: https://issues.apache.org/jira/browse/SPARK-12863 > Project: Spark > Issue Type: Bug > Components: Spark Core, SQL > Affects Versions: 1.6.0 > Reporter: Milad Khajavi > > Here I struggle with spark api to convert the result of count to convert that > to KeyValue case class. I think there is no api for changing the column of > Dataset and mapping them to new case class. > case class LogRow(id: String, location: String, time: Long) > case class KeyValue(key: (String, String), value: Long) > val log = LogRow("1", "a", 1) :: and so on > log.toDS().groupBy(l => {(l.id, l.location)}).count().toDF().toDF("key", > "value").as[KeyValue].printSchema() -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org