Есть ли способ сделать трансляцию присоединиться в Spark 2.1 в Java

Question

Я знаю, что в scala существует способ, как упомянуто ниже.

val joined_df = df1.join(broadcast(df2), "key")

Как я могу выполнить широковещательное соединение в Java.Нужно ли делать sc.broadcast (df2) и использовать это в соединении?Будет ли это называться трансляцией?

Answer 1

Как я могу выполнить широковещательное соединение в Java.

Точно так же.

import static org.apache.spark.sql.functions.broadcast;

Datset<Row> joined = df1.join(broadcast(df2), "key");