如何从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的方法,如上例所示.

我也知道withColumnapi但不确定实现.

谢谢.

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))

也就是说,如果要添加整数.如果要添加常量字符串,请在选择后使用此字符串

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