如何解决java中的Beam框架无法解析外部表
我使用的是光束 2.19。当我尝试解析一些包含 CREATE EXTERNAL TABLE 的 BEAM sql 时:
String sql = "CREATE EXTERNAL TABLE ext_table (value INTEGER) TYPE text LOCATION "
+ "'ext_table.csv' TBLPROPERTIES '{\"format: \"Excel\"}';\n"
+ "SELECT * ext_table;";
final sqlParser.ConfigBuilder configBuilder =
sqlParser.configBuilder()
.setQuoting(Quoting.BACK_TICK)
.setUnquotedCasing(Casing.UNCHANGED)
.setQuotedCasing(Casing.UNCHANGED);
final sqlParser.Config config = configBuilder.build();
sqlParser parser = sqlParser.create(sql,config);
sqlNode rootNode = parser.parseQuery();
System.out.println(rootNode.toString());
我收到此异常。
java.lang.RuntimeException: org.apache.calcite.sql.parser.sqlParseException: Encountered "CREATE" at line 1,column 1.
Was expecting one of:
"ABS" ...
"ALTER" ...
"ARRAY" ...
....etc
所以我想知道解析带有外部表声明的 sql 的正确方法是什么。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。