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 | +------+---+---+---+
1条答案
按热度按时间xmd2e60i1#
过滤
null之前的值pivot检查以下代码。