我想知道如何使用JAVA从Spark SQL中的domain-specific language(DSL)函数调用UDF函数。我有UDF函数(仅举个例子): @Override
public Boolean callsqlContext.sql("SELECT p0.value FROM values p0 WHERE equals(p0.value,
需要在结构化流中对UDF中的表执行一些查询。问题是,在UDF内部,如果我尝试使用spark.sql,就会得到空指针异常。这里最好的方法是什么。基本上,我需要从一个表中流,然后使用这些数据从另一个表执行一些范围查询。例如: val query = "select count(*) from appleMart whereappleId='"+appleI