我知道scala中有一种方法，如下所述。
val joined_df = df1.join(broadcast(df2), "key")
如何在java中进行广播连接。我必须做sc.broadcast（df2）并在join中使用它吗？那会叫广播会合吗？
5n0oy7gb1#
如何在java中进行广播连接。完全一样。
import static org.apache.spark.sql.functions.broadcast; Datset<Row> joined = df1.join(broadcast(df2), "key");
1条答案
按热度按时间5n0oy7gb1#
如何在java中进行广播连接。
完全一样。