source Typea null a aa a bb a ccsource null aa bb cca. 1. 1 1 1
source Type
a null
a aa
a bb
a cc
source null aa bb cc
a. 1. 1 1 1
如何停止旋转。包含空值的列
xmd2e60i1#
过滤 null 之前的值 pivot 检查以下代码。
null
pivot
scala> df.show(false)+------+----+|source|type|+------+----+|a |null||a |aa ||a |bb ||a |cc |+------+----+scala> df .filter($"type".isNotNull) .groupBy($"source") .pivot($"type") .agg(count($"type")) .show(false)+------+---+---+---+|source|aa |bb |cc |+------+---+---+---+|a |1 |1 |1 |+------+---+---+---+
scala> df.show(false)
+------+----+
|source|type|
|a |null|
|a |aa |
|a |bb |
|a |cc |
scala> df
.filter($"type".isNotNull)
.groupBy($"source")
.pivot($"type")
.agg(count($"type"))
.show(false)
+------+---+---+---+
|source|aa |bb |cc |
|a |1 |1 |1 |
1条答案
按热度按时间xmd2e60i1#
过滤
null之前的值pivot检查以下代码。