SPARK 1.6、SCALA、MAVEN 我已经从RDD创建了一个数据帧，并尝试过滤掉cola=为null或空字符串且colb =2或3的所有记录。 我试过这样的东西。df.filter(WHERE $"COLA isnull AND COLB =02 & 03")
But unfortunately getting error as "cannot resolve'COLA isnull where COLB =02 & 03
浏览 12提问于2019-09-30得票数 0
回答已采纳
我有一个简单的Hive外部表，它是在S3之上创建的(文件是CSV格式的)。当我运行hive查询时，它会显示所有记录和分区。但是，当我在Spark中使用相同的表时( Spark在分区列上有一个where条件)，它不会显示应用了分区筛选器。然而，对于Hive托管表，Spark可以使用分区信息并应用分区筛选器。是否有任何标志或设置可以帮助我使用星火中<
浏览 0提问于2019-08-24得票数 3
1回答
我正在编写一个查询，以便从表A中获取满足表B中记录的条件的记录。SF YesName Profession City NewJobOffer我可以使用where为什么使用spark sql？Where子句比较列添加select那些记录还是连接列本身，哪个更好？
浏览 4提问于2016-08-11得票数 3
1回答
我使用的是Spark2.4.7，并且我已经实现了普通的吡火花卡桑德拉连接器，但是有一个用例，我需要实现基于键的连接器，我没有得到有用的博客/教程围绕它，有人请帮助我。我试过普通的火花放电-卡桑德拉连接器，它工作得很好。现在，我希望实现基于键的连接器，我找不到。
Cassandra通常加载整个表，但我不想加载整个表，而是在源上运行查询并获取所需的数据。通过基于键的方法，我想使用一些键来获取数据，比如使用where</e
浏览 3提问于2022-03-25得票数 1
我对Spark非常陌生，我有一个查询，它从两个Oracle表中获取数据。这样的表必须由一个字段连接，该字段可以很好地处理下面的代码。但是，我需要应用过滤器，就像在Oracle "where“子句中那样。例如，雇用年龄在25岁至50岁之间的员工。我还必须应用GroupBy过滤器，并使用OrderBy对最终结果进行排序。问题是，唯一正确执行的操作是从表中检索所有数据以及它们之间的连接。其余的过滤器根本没有应用，
浏览 6提问于2015-07-08得票数 2
回答已采纳
1回答
我正在将MongoDB连接到Spark，并希望使用查询加载数据。df = sqlContext.read.format("com.mongodb.spark.sql").options(collection='test', query = {'name' :'jack如何在星火中复制与此查询db.test.find({'name':'jack'})相同的内容？
浏览 2提问于2017-04-11得票数 2
回答已采纳
DataSet<Row> a = spark.read().format("com.memsql.spark.connector").option("query", "select * from a")Sring xstring = "...select all values of x from a and make comma separated string"
DataSet<Row> b = spark.read().format(
浏览 20提问于2020-02-15得票数 0
回答已采纳
1回答
我创建了一个内容视图，它使用和操作符和使用OR运算符的另一个过滤器组(见下面的图像)创建了一个过滤器组，该操作符是ANDed。但是，所构造的查询是全部，运算符和组甚至没有应用。以下是查询的WHERE子句：( // Content: Type (= On-demand)
node__field_format.field_format_target_idDATE_FORMAT(('2021-10-19T18:53:48' +
浏览 0提问于2021-10-19得票数 -2
回答已采纳
我是新来的GAE，请原谅我太天真了。例如: select * from GaeUser返回所有的实体。就像，谢谢你看这个！！
浏览 5提问于2014-08-06得票数 1
回答已采纳
2回答
我使用PostgreSQL9.1，希望从表中选择一些记录。WHERE phonenumber = ?它应满足以下条件：
重要的是用户is是唯一的。因此，结果应该是一个单一的记录。当我使用上述<em
浏览 0提问于2014-06-25得票数 0
我试图从来自多列的不等于(！=)值的dataframe中筛选记录。我能使它工作，但在解释过滤器的工作方式上有困难。问题陈述
val conf = new SparkConf().setAppName("Test").
浏览 0提问于2019-05-10得票数 0
回答已采纳
我有一个类似如下的Spark SQL查询： Select * from xTable a Where Exist (filter subquery) AND (a.date IN (Select max(b.date) from xTable b)) 在某些情况下(当没有提供筛选器表时)，我的filter subquery应该简单地执行一个Select 1。每当我在Impala中运行它时，它都会返回记录，在Hive<
浏览 15提问于2020-03-31得票数 0
1回答
我正在阅读spark.sql.execution.datasources.jdbc.JDBCRelation的源代码。为什么每一行都必须是唯一的？有什么例子吗？动机是什么？如果我们有重复的怎么办？
浏览 28提问于2018-06-26得票数 -2
回答已采纳
15回答
HAVING和WHERE在SQL SELECT语句中有什么区别？编辑:我已经将Steven的答案标记为正确的答案，因为它包含了链接上的关键信息：
我所见过的WHERE没有GROUP BY，也是我困惑的开始
浏览 3提问于2008-11-13得票数 283
回答已采纳
在where中使用条件与在join中使用条件的结果有区别吗？在实际查询中，我可以将AND "noteReads"."id" IS NULL放在where或join中。这有关系吗？where子句中带有AND "noteReads"."userId" = 1的第一个版本：
SELECT count(distinct("notes".&quo
浏览 5提问于2020-11-10得票数 0
回答已采纳
在我的一个查询中，我想排除从WHERE子句中的正则表达式条件中获得的记录。这意味着如果在一个具有500记录的表中，当我在中使用正则表达式时，就会得到100记录，所以我只想要剩下的记录就意味着rest 400记录。查询是这样的。
Eg:- select ........
浏览 1提问于2018-02-28得票数 0
回答已采纳
2回答
我想从视图中的下拉列表中获取数据，数据已经在我的mssql数据库中了。select a);where b.Adress == areaName{
return Json(new Emp
浏览 7提问于2022-10-02得票数 0
6回答
带连接的条件过滤
、、
在具有单个参数的存储过程中，有一个性质类似于以下查询的查询： ID, FileName Document我使用这个查询来过滤带联接的Document表返回的结果。
浏览 12提问于2016-03-26得票数 6
回答已采纳
1回答
我想在某一特定的到期日之前一天(几天)发送电子邮件。
以及相应的自动操作的服务器操作。
我想知道“基于时间条件”是否有效，就我所尝试和研究的情况而言，这似乎是一个缺陷，还是不起作用。
浏览 1提问于2016-06-20得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
