小编The*_*iem的帖子

我试图运行第一个示例。

源代码是：

/*keyWordCount.java */
            import org.apache.spark.*;
            import org.apache.spark.api.java.*;
            import org.apache.spark.api.java.function.*;
            import org.apache.spark.rdd.*;
            import org.apache.spark.api.java.JavaRDD;
            import java.util.*;

            public class keyWordCount {

                public static void main(String[] args) {
                    SparkConf conf = new SparkConf().setAppName("keyWordCount");
                    JavaSparkContext sc = new JavaSparkContext(conf);
                    JavaRDD<String> textFile = sc.textFile("output");
                    JavaRDD<String> dictFile = sc.textFile("keyword");
                    JavaRDD<String> words = textFile.flatMap(new FlatMapFunction<String, String>() {
                        @Override public Iterable<String> call(String s) { return Arrays.asList(s.split(" ")); }
                    });
                }
            }

当我使用 mvn compile package 进行编译时，不断出现以下错误：

[错误] 编译错误：[信息] ----------------------------------------- -------------------- [错误] /home/cyberliem/TestSpark/src/main/java/keyWordCount.java:[16,81] 错误：不是抽象的并且不会覆盖 FlatMapFunction 中的抽象方法 …

我正在研究计算机体系结构。在逻辑运算部分，它提出了这个问题：

哪些操作可以隔离单词中的字段？

1. 和
2. 左移后右移

我不确定这些规定的操作如何在一个单词中隔离一个字段。我尝试搜索示例，但找不到任何示例。有人能为此提供更深入的解释和例子吗？谢谢。