Scala在SparkJavaAPI中的一些和没有等价

Question

我在Spark Java API项目中编写了一个mapToPair函数。我需要有一个类似于Scala None的功能，所以对于一个特定的地图，我可能不返回任何东西（Scala中没有）

JavaPairRDD<DateTime,Row> sensorDataDoubleRDD= sensorDataDoubleDF.toJavaRDD().mapToPair(new PairFunction<Row,DateTime,Row>() 
{
    private static final long serialVersionUID = 8355799038879757766L;
    @Override
    public Tuple2<DateTime,Row> call(Row row) {

        //return new Tuple2("s",1);
        return null;    
    }
});

System.out.println("the count is: "+sensorDataDoubleRDD.count());

例如，运行上述代码总是返回一个正的计数值，而不是0。

Answer 1

如果你使用的是Java8，你可以使用可选，这与scala中的选项有些相似。你可以在这里了解更多。

或者，您可以通过新建一些（数据）创建一些对象，通过scala创建无。无$。MODULE$，因为无是单例。