我可以在foreachRDD中创建一个DF,如果我不尝试使用Case类,只需使用toDF()创建列的默认名称,或者通过toDF("c1,"c2")为它们分配默认名称。当我尝试使用Case类时,在查看了这些示例之后,我得到了:如果我在Case Class语句周围移动,那么我得到:
toDF() not part of RDD
使用火花笔记本来更新accumulo表。使用和中指定的方法。下面是我在笔记本上逐字列出的内容和答复:val bwConfig = new BatchWriterConfig(Mutation.java:163) at org.apache.accumulo.core.data.Mutation.put(Mutation.java:211)的java.lang.IllegalStateExcep
我创建了一个简单的Maven项目(Packaging type - Jar),它依赖于Spring和我的Sql库(mysql-connector)。当我用$mvn package打包这个项目时,在成功执行这个命令之后,我确实得到了一个jar文件。The `jar-with-dependencies` descriptor builds a JAR archive with the contents of the main project jar along with the unp