【发布时间】:2018-01-16 23:53:21
【问题描述】:
我正在尝试根据列 value 过滤掉表 rows。
我有一个dataframe:
+---+-----+
|id |value|
+---+-----+
|3 |0 |
|3 |1 |
|3 |0 |
|4 |1 |
|4 |0 |
|4 |0 |
+---+-----+
我想创建一个新的dataframe 删除所有rows 和value!=0:
+---+-----+
|id |value|
+---+-----+
|3 |0 |
|3 |0 |
|4 |0 |
|4 |0 |
+---+-----+
我认为语法应该是这样的,但不能正确:
val newDataFrame = OldDataFrame.filter($"value"==0)
【问题讨论】:
标签: scala apache-spark apache-spark-sql filtering