程序包org.elasticsearch.spark.sql.api.java不存在

[missence]

ERROR|compiler.err.doesnt.exist LINE:COLUMN 16:44 程序包org.elasticsearch.spark.sql.api.java不存在

import com.qihoo.qsql.exec.Requirement; import org.apache.spark.sql.catalyst.expressions.Attribute; import org.apache.spark.sql.Row; import java.util.stream.Collectors; import org.apache.spark.sql.SparkSession; import java.util.Collections; import java.util.Map; import java.util.HashMap; import com.qihoo.qsql.exec.spark.SparkRequirement; import java.util.regex.Pattern; import scala.collection.JavaConversions; import java.util.AbstractMap.SimpleEntry; import com.qihoo.qsql.codegen.spark.SparkJdbcGenerator; import java.util.regex.Matcher; import com.qihoo.qsql.codegen.spark.SparkElasticsearchGenerator; import org.elasticsearch.spark.sql.api.java.JavaEsSparkSQL; import org.apache.spark.sql.Dataset; import java.util.Arrays; import org.apache.commons.lang.StringEscapeUtils; import java.util.Properties; import java.util.List;

at com.qihoo.qsql.codegen.ClassBodyWrapper$WithClassPathInMemoryCompiler.compile(ClassBodyWrapper.java:162)
at com.qihoo.qsql.codegen.ClassBodyWrapper$WithClassPathInMemoryCompiler.singleCompile(ClassBodyWrapper.java:123)
at com.qihoo.qsql.codegen.ClassBodyWrapper.compileSourceAndLoadClass(ClassBodyWrapper.java:64)
at com.qihoo.qsql.codegen.ClassBodyWrapper.compile(ClassBodyWrapper.java:101)
... 20 more

ERROR|compiler.err.cant.resolve.location LINE:COLUMN 36:31 找不到符号 符号: 变量 JavaEsSparkSQL 位置: 类 Requirement31037

使用客户端连接服务端，mysql和es联合查询，采用spark处理，报对应的api不存在