gpt4 book ai didi

scala - Cassandra spark 连接器 joinWithCassandraTable 在具有不同名称的字段上

转载 作者:行者123 更新时间:2023-12-01 07:25:24 25 4
gpt4 key购买 nike

我希望在 RDD 和 cassandra 表上进行连接,它们的名称与相同的键不同
前(简化):

case class User(id : String, name : String)


case class Home( address : String, user_id : String)

如果想做:
rdd[Home].joinWithCassandraTable("testspark","user").on(SomeColumns("id"))

我怎样才能精确地进行连接的字段的名称。
而且我不想将 rdd 映射为只有正确的 id,因为我想在 joinWithCassandraTable 之后加入所有值。

最佳答案

您可以像在选择中一样使用“as”语法来更改连接列的映射。

一个例子

sc.cassandraTable[Home]("ks","home").joinWithCassandraTable("ks","user").on(SomeColumns("id" as "user_id")).collect

将用户表中的“id”列映射到 Home 中的“user_id”字段案例类。

关于scala - Cassandra spark 连接器 joinWithCassandraTable 在具有不同名称的字段上,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32209385/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com