我有SQL查询
load1.sqlContext()
.sql("select object_id, parent_id, object_id as root_id, attr_id, attr_name, value from load l1 where not exists (select 1 from load l2 where l2.object_id = l1.parent_id)").show(false);
结果查询 enter image description here个
try 重写，但得到异常
Dataset<Row> test = load1.select(
functions.col("object_id"),
functions.col("parent_id"),
functions.col("object_id").as("root_id"),
functions.col("attr_id"),
functions.col("attr_name"),
functions.col("value"));
test.where(not(exists(load1.col("object_id"), x -> x.equalTo(test1.col("parent_id"))))).show(false);
例外情况
cannot resolve 'exists(load.object_id, lambdafunction((x_1 = load.parent_id), x_1))' due to argument data type mismatch: argument 1 requires array type, however, 'load.object_id' is of string type.