java - 如何从 Java 中的 Dataframe 编码中选择常量值

Question

我有一个列数固定的数据框 df1。我已经应用了与另一个数据框 df2 的内部连接。

但是，在编写选择时，我需要选择一些我目前无法选择的常数。

我已经阅读了 scala 中的示例，但相应的 java 不工作。

df1.join(df2).filter(df1.col("a1").$eq$eq$eq(df2.col("a1")))
.select(df1.col("a1"), df1.col("a2"), df2.col("a2"), 8)

如上例所示，建议一种选择 8 的方法。

我也知道 withColumn api，但不确定实现。

谢谢。

Answer 1

这应该有效。

val joinedDF = df1.join(df2).filter(df1.col("a1").$eq$eq$eq(df2.col("a1")))
.select(df1.col("a1"), df1.col("a2"), df2.col("a2")).withColumn("constant", lit(8))

也就是说，如果你想添加一个整数。如果你想添加一个常量字符串，在select之后使用这个

.withColumn("constantString",lit("some_string"))