且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

如何使用 Java 在 Spark SQL 中加入多列以在 DataFrame 中进行过滤

更新时间:2023-09-18 20:04:52

Spark SQL 在 Column 上提供了一组标记为 java_expr_ops 的方法,这些方法是为 Java 互操作性而设计的.它包括 and(另见 or) 方法,可以在这里使用:

Spark SQL provides a group of methods on Column marked as java_expr_ops which are designed for Java interoperability. It includes and (see also or) method which can be used here:

a.col("x").equalTo(b.col("x")).and(a.col("y").equalTo(b.col("y"))