匿名类没有参数

Question

我正在学习Apache Spark。鉴于下面的java使用java实现spark，我对它的一些细节感到困惑。

public class JavaWordCount { 
    public static void main(String[] args) throws Exception { 
    if (args.length < 2) { 
     System.err.println("Usage: JavaWordCount <master> <file>"); 
     System.exit(1); 
    } 

    JavaSparkContext ctx = new JavaSparkContext(args[0], "JavaWordCount", 
     System.getenv("SPARK_HOME"), System.getenv("SPARK_EXAMPLES_JAR")); 
    JavaRDD<String> lines = ctx.textFile(args[1], 1); 

    JavaRDD<String> words = lines.flatMap(new FlatMapFunction<String, String>() { 
     public Iterable<String> call(String s) { 
     return Arrays.asList(s.split(" ")); 
     } 
    }); 

    JavaPairRDD<String, Integer> ones = words.map(new PairFunction<String, String, Integer>() { 
     public Tuple2<String, Integer> call(String s) { 
     return new Tuple2<String, Integer>(s, 1); 
     } 
    }); 

    JavaPairRDD<String, Integer> counts = ones.reduceByKey(new Function2<Integer, Integer, Integer>() { 
     public Integer call(Integer i1, Integer i2) { 
     return i1 + i2; 
     } 
    }); 

    List<Tuple2<String, Integer>> output = counts.collect(); 
    for (Tuple2 tuple : output) { 
     System.out.println(tuple._1 + ": " + tuple._2); 
    } 
    System.exit(0); 
    } 
} 

根据我的理解，开始行12，它通过一个匿名类FlatMapFunction到lines.flatMap()作为参数。那么String s是什么意思？看起来它没有通过创建的String s作为参数，那么FlatMapFunction<String,String>(){}类将如何工作，因为没有特定的参数传入？

Answer 1

您传递的匿名类实例正在重写call(String s)方法。无论接收到这个匿名类实例是什么想要在其执行过程中使用该方法：它将（以某种方式）构造字符串并将它们（直接或间接）传递给你传入的任何方法call()。

所以，你不调用你定义的方法不是一个担心：其他的事情是这样做的。

这是匿名内部类的常见用例。方法m()期望通过实现Blah接口的东西，而Blah接口在其中具有frobnicate(String s)方法。因此，我们有

m(new Blah() { 
    public void frobnicate(String s) { 
     //exciting code goes here to do something with s 
    } 
}); 

称它为和m方法现在将能够利用这种情况下，实现Blah，并在其上调用frobnicate()。

也许m看起来是这样的：

public void m(Blah b) { 
    b.frobnicate("whatever"); 
} 

现在正在调用的是我们在内部类写的frobnicate()方法，并且当它运行时，该参数s将被设置为"whatever"。

Answer 2

你在这里所做的就是传递一个FlatMapFunction作为flatMap方法的参数;您通过FlatMapFunction取代呼叫（String s）将：

JavaRDD<String> words = lines.flatMap(new FlatMapFunction<String, String>() 
{ 
    public Iterable<String> call(String s) 
    { 
    return Arrays.asList(s.split(" ")); 
    } 
}); 

实施lines.flatMap可能看起来像这样的实例代码：

public JavaRDD<String> flatMap(FlatMapFunction<String, String> map) 
{ 
    String str = "some string"; 
    Iterable<String> it = map.call(str); 
    // do stuff with 'it' 
    // return a JavaRDD<String> 
}