如何解决使用 JavaSession 在 Spark Java 中保存 Hbase 数据时出错
我的代码在“Java Spark”中,我需要解决最后一行中的问题。
Calendario calendario = new Calendario();
Dataset<Row> test = spark.createDataFrame(Arrays.asList(
new Calendario("999","2"),new Calendario("888",new Calendario("777","2")
),Calendario.class);
String catalog = "{\n" + "\"table\":{\"namespace\":\"default\",\"name\":\"novatabela\"},\n" + "\"rowkey\":\"key\",\n"
+ "\"columns\":{\n" + "\"rowKey\":{\"cf\":\"rowkey\",\"col\":\"key\",\"type\":\"string\"},\n"
+ "\"tipoNi\":{\"cf\":\"c\",\"col\":\"campoA\",\n"
+ "\"ni\":{\"cf\":\"c\",\"col\":\"campoB\",\n"
+ "}}";
Map<String,String> optionsMap = new HashMap();
optionsMap.put(HBaseTableCatalog.tableCatalog(),catalog);
optionsMap.put(HBaseTableCatalog.newTable(),"5");
System.out.println(catalog);
System.out.println(optionsMap);
test.write().options(optionsMap).format("org.apache.spark.sql.execution.datasources.hbase").save();
我收到错误:
线程“main”中的异常java.lang.IllegalArgumentException:不能 从空字符串创建路径
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。