程序包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不存在