问题标签 [right-join]

如何在将一个文件的数据加入到 spark 中的另一个文件之前基于一个变量汇总一个文件的数据？我需要加入这两个文件，这样该列就不应该有任何重复的键。示例：一个文件的数据

第二个文件的数据

滚动第一个文件后，它应该像

滚动第二个文件后，它应该像

在滚动这些文件之后，我想在 Spark 中进行左连接、右连接和其他类型的连接。

你好，

我有以下 SQL 查询，运行大约需要 4 秒：

该查询连接以下 3 个表：

订单、清单和 Tracking_Update。

该查询将返回满足以下条件的订单：

1. 任何交货状态的订单 < 30 天
2. 订单 > 30 天，而不是交货状态

如果该订单的最新 tracking_update 的 status_type 为“D”或“XD”，则该订单被视为已送达

现在，订单列在订单表中。Order 表有一个名为 manifest_id 的列，它引用了在上传订单时创建的 Manifest。

一个清单可以有多个订单。这用于确定过去 30 天内是否已上传订单。

最后， tracking_update 表包含每个订单的 tracking_updates。一个订单可以有多个 tracking_updates。

目前，tracking_update 表的记录长度超过 1M。

下面列出了每个表的创建语句：

Tracking_Update 表：

清单表：

这里也是用 JSON 导出的 select 语句的解释：

任何帮助表示赞赏

更新

这是我正在使用的当前查询，它更快：

这有效...

但我不需要按用户 ID 排序，这不起作用......

这也不...

这也不...

我需要按“id”或“timestamp”DESC 排序，以便最先显示最新的帖子。非常感谢您的帮助。谢谢你！

S&P500我有一张指数中每只股票交易的历史股票价格表。

每个工作日，表中插入 500 条新记录historical_prices：

交易品种，close_date，close_price。

由于多种原因，该过程经常失败，仅添加了一小部分记录。

星期四运行正确（500 条新记录），星期五失败（仅添加 400 条记录）。

我需要确定剩余的 100 条未添加的记录，以重新运行并完成该过程。

嵌套查询会是最有效的方法吗？选择星期四的 500 条记录，并对照星期五的 400 条记录进行衡量）

先谢谢了！

我正在尝试加入两个 SQL 表。操作成功，但是Location结果集中的字段正在从错误的表中提取数据。

JOIN 语句中的两个表都有一个名为的字段location，结果集应该从RDet表中提取（即 RDet.location）。但是结果集数据显示它是从RDoc表中提取的，就像我指定的一样RDoc.location。

我的 SQL 查询有问题。当我使用多个 JOIN 时，结果是错误的。

当我只使用

这是正确的。但是当我使用 2 个连接时。两者的结果是一样的。有人可以帮我吗？

经过搜索，我知道 JPQL 中没有 Right Join。我看到还有另一种使用 JPA 双向实现它的方法（不是右连接，而是使用 pojo 对象），但我在控制台中注意到它对数据库进行了多次调用，例如见下表。

我想要平面表中的所有行，并且只想要用户表中的匹配行

现在，如果我使用 jpql birectional 并使用对象获取例如

上面的代码将在 where condition flat_ID = ? （在这种情况下是 4 次），我认为这不是很好的表现。

那么有什么方法可以让 JPQL 在不影响性能的情况下实现正确的连接。

实体配置

我正在尝试在 medoo 中求和。

我现在的sql是这样的：

调试记录以下语句：

我想要实现的是：

有人知道如何在 medoo 中发表此声明吗？

[编辑 1]

找到了实现这一目标的另一种方法

这将对数据库进行更多调用，但只要SELECT语句不支持聚合函数，它就可以正常工作。

我正在尝试在 Spark 中执行连接，因为我知道左侧的一个键在另一个 RDD 中没有对应的值。

文档说如果没有找到密钥，它应该使用 None 作为选项执行连接，但我不断收到类型不匹配错误。

这里有什么见解吗？

我在 mySQL 查询中有一个非常基本的问题。我的代码是

结果，我的决赛桌有两次“中”列。表有这些列：

但我想要这张表，不使用 member.mid、name、mtype、debt、year、description。

有什么解决办法吗？顺便说一句，对不起我的英语。