小编Moh*_*ana的帖子

我有一个场景,我将接收由我的火花流程序处理的流数据,并且每个间隔的输出将附加到我现有的cassandra表中.

目前我的火花流程序将生成一个数据框,我需要保存在我的cassandra表中.我目前面临的问题是当我使用下面的命令时,我无法将数据/行附加到我现有的cassandra表中

dff.write.format("org.apache.spark.sql.cassandra").options(Map("table" -> "xxx", "yyy" -> "retail")).save()

我已阅读以下链接http://rustyrazorblade.com/2015/08/migrating-from-mysql-to-cassandra-using-spark/,他将mode ="append"传递给save方法但其抛出语法错误

此外,我还能够从以下链接了解我需要修复的位置 https://groups.google.com/a/lists.datastax.com/forum/#!topic/spark-connector-user/rlGGWQF2wnM

如何解决这个问题需要帮助.我正在scala中编写我的spark流媒体作业

我正在研究一个java项目来优化现有代码.目前我正在使用BufferedReader/FileInputStream在Java中将XML文件的内容读取为String.

但我的问题是,有没有更快的方式来读取XML内容.SAX/DOM比BufferedReader/FileInputStream快吗？

需要有关上述问题的帮助.

提前致谢.

下面是我的控制器方法定义

@Autowired
private HttpServletRequest request;

@PostMapping(path = "/abc")
public String createAbc(@RequestBody HttpServletRequest request)
        throws IOException {

    logger.info("Request body: "+request.getInputStream());

    return "abc";

}

我想要做的就是打印内容以请求正文。但是当我发出 POST 请求时，我看到以下错误：

类型定义错误：[简单类型，类javax.servlet.http.HttpServletRequest]；嵌套异常是 com.fasterxml.jackson.databind.exc.InvalidDefinitionException：无法构造实例javax.servlet.http.HttpServletRequest（没有创建者，如默认构造，存在）：抽象类型要么需要映射到具体类型，有自定义反序列化器，要么包含其他类型信息\n 在 [来源: (PushbackInputStream); 行：1，列：2]",

我使用的是 Spring boot 2.x 版本。知道我的代码有什么问题吗？