Код: Выделить всё
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.function.Function;
public class SimpleApp {
public static void main(String[] args) {
SparkConf conf = new SparkConf().setAppName("wordCount").setMaster("local");
JavaSparkContext sc = new JavaSparkContext(conf);
JavaRDD input = sc.textFile("/bigdata/softwares/spark-2.1.0-bin-hadoop2.7/testdata/a.txt");
System.out.println();
Long bCount = input.filter(new Function(){
public Boolean call(String s){return s.contains("yes");}
}).count();
Long cCount = input.filter(new Function(){
public Boolean call(String s){return s.contains("ywq");}
}).count();
System.out.println("yes:"+bCount+" ywq:"+cCount+" all:");
// sc.stop();
}
}
Код: Выделить всё
org.apache.spark
spark-core_2.11
2.1.0
org.apache.maven.plugins
maven-shade-plugin
2.3
package
shade
Все ресурсы Maven упакованы в jar-файл, запустите время, сообщили о следующих ошибках, я только начал учиться, кто знает, как научить, спасибо

Подробнее здесь: https://stackoverflow.com/questions/428 ... n-resource