0

count結果をDataFrameに変換せずに、操作の列の名前を変更するにはどうすればよいですか?

case class LogRow(id: String, location: String, time: Long)
case class KeyValue(key: (String, String), value: Long)

val log = LogRow("1", "a", 1) :: LogRow("1", "a", 2) :: LogRow("1", "b", 3) :: LogRow("1", "a", 4) :: LogRow("1", "b", 5) :: LogRow("1", "b", 6) :: LogRow("1", "c", 7) :: LogRow("2", "a", 1) :: LogRow("2", "b", 2) :: LogRow("2", "b", 3) :: LogRow("2", "a", 4) :: LogRow("2", "a", 5) :: LogRow("2", "a", 6) :: LogRow("2", "c", 7) :: Nil
log.toDS().groupBy(l => {
  (l.id, l.location)
}).count().toDF().toDF("key", "value").as[KeyValue].show

+-----+-----+
|  key|value|
+-----+-----+
|[1,a]|    3|
|[1,b]|    3|
|[1,c]|    1|
|[2,a]|    4|
|[2,b]|    2|
|[2,c]|    1|
+-----+-----+
4

1 に答える 1

1

必要なタイプに直接マップするだけです：

log.toDS.groupBy(l => {
  (l.id, l.location)
}).count.as[KeyValue]
于 2016-02-13T12:29:23.603 に答える