如何使用SparkR在Spark SQL中传递变量？

Question

我是SparkR新手。我正在尝试使用Qubole Notebook使用SparkR在数据集上编写查询。进行了几个过程，但没有得到输出。

数据：Table_A

ID      Name     month      year
1        A         2        2020
2        B         2        2019
3        c        12        2019

所需的输出：

ID      Name     month      year
1        A         2        2020

<< img src =“ https://image.soinside.com/eyJ1cmwiOiAiaHR0cHM6Ly9pLnN0YWNrLmltZ3VyLmNvbS9pSHlmQy5wbmcifQ==” alt =“在此处输入图像描述”>

代码：

month_value = 2year_value = 2020

处理1：

temp_data = sql（“选择 *从Table_A其中month = $ month_value和year = $ year_value“）

处理2：

temp_data = sql（s“选择 *从Table_A其中month = $ month_value和year = $ year_value“）

处理3：

temp_data = sql（“选择 *从Table_A其中month = {0}和year = {1}“。format（month_value，year_value））>

处理4：

temp_data = sql（“选择 *从Table_A其中month = $ {month_value}，year = $ {year_value}“）

[请帮助我解决这个问题。谢谢[]

我是SparkR新手。我正在尝试使用Qubole Notebook使用SparkR在数据集上编写查询。采取了几个过程，但没有得到输出。数据：Table_A ID名称月份年份1 ...

Answer 1

过滤

可以使用where函数中的sql子句或直接使用filter函数来完成。