xception in thread "main" java.lang.IllegalArgumentException: No matching method found: getAppender for class org.slf4j.impl.Log4jLoggerAdapter at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:53) at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) at backtype ...
因为Spark内部写文件方式其实调用的都是Hadoop的函数,所以我们也可以通过Spark实现多文件输出。Spark内部没有多文件输出的函数供大家直接调用,我们自己实现这个功能也是很简单的。我们可以通过调用saveAsHadoopFile函数并自定义一个OutputFormat类即可,代码如下: import org.apache.hadoop.io.NullWritable i ...