我正在编写一个存储过程,它应该将一个表从我们的生产环境同步到我们的测试环境(每天一次)。我有两张桌子。为了简单起见,让我们称它们为米和测量。Meters = [Meter_id, Location]我希望保持测量同步,并假设我可以手动向我的测试环境中添加一个仪表我已经设置了一个名为db_test的数据库链接到我们的测试服务器。MERGE INTO Measurements@db_test meas_test
USING (SELECT va
我正在尝试使用joinWith在Spark SQL中连接两个仪表读数的数据集,这样返回的类型就是Dataset(读数,读数)。目标是根据日期列将第一个数据集中的每一行(称为当前)与其在第二个数据集中的上一条记录(称为上一条)进行匹配。 我需要首先加入计量键,然后通过比较日期来加入,找到比当前读数日期(即前一个读数)小的下一个最大日期。 这是我尝试过的,但我认为这太微不足道了。我也得到了一个‘无法解决’的最大错误。 val joined = Current.joinWith( (Current("Meter_Key") === Pre
我的桌子的结构如下:`date` date NOT NULL,`identifier` CHAR(20),`duration` int,`price_quote` decimal(16,6),为了获得每个符号的最新条目(由于国庆节,它们不一定是同一天),我会:
SELECT market_trend_record.sy