scala - 连接类型是否定义为 Apache Spark 中某处可访问的常量？

Question

粗略浏览了 Spark 代码库后，我还没有找到它们。在大多数文档和教程示例中，人们似乎使用“裸”字符串文字来指定连接类型。 Spark 是否提供将“leftouter”、“inner”、“cartesian”等定义为 public 的对象或类 val s，还是仅仅依赖于字符串文字的约定？

也就是说，是否有替代方案:

dataframe.join(
  right = anotherDataFrame,
  joinExprs = expr("1 = 1"),
  joinType = "leftouter"
)

这看起来像:

dataframe.join(
  right = anotherDataFrame, 
  joinExprs = expr("1 = 1"),
  joinType = SparkJoins.LeftOuter
)

?

Answer 1

您可以使用包中包含的对象，例如，为每个文字使用以下对象:

对于“内部”=> org.apache.spark.sql.catalyst.plans.Inner.sql

对于“左外”=> org.apache.spark.sql.catalyst.plans.LeftOuter.sql

等

来源: https://github.com/apache/spark/blob/master/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/joinTypes.scala