过滤器和Scala Spark SQL中的位置之间的区别 [英] Difference between filter and where in scala spark sql

问题描述

我都尝试过，但是都起作用

I've tried both but it works same

示例

val items =  List(1, 2, 3)

使用过滤器

employees.filter($"emp_id".isin(items:_*)).show

在何处使用

employees.where($"emp_id".isin(items:_*)).show

两者的结果相同

+------+------+------+-------+------+-------+
|EMP_ID|F_NAME|SALARY|DEPT_ID|L_NAME|MANAGER|
+------+------+------+-------+------+-------+
|     6|    E6|  2000|      4|    L6|      2|
|     7|    E7|  3000|      4|    L7|      1|
|     8|    E8|  4000|      2|    L8|      2|
|     9|    E9|  1500|      2|    L9|      1|
|    10|   E10|  1000|      2|   L10|      1|
|     4|    E4|   400|      3|    L4|      1|
|     2|    E2|   200|      1|    L2|      1|
|     3|    E3|   700|      2|    L3|      2|
|     5|    E5|   300|      2|    L5|      2|
+------+------+------+-------+------+-------+

推荐答案

使用给定条件过滤行. 这是过滤器的别名.

filter只是该函数的标准Scala(通常是FP)名称，而where是针对喜欢SQL的人的.

filter is simply the standard Scala (and FP in general) name for such a function, and where is for people who prefer SQL.

这篇关于过滤器和Scala Spark SQL中的位置之间的区别的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！