如何访问申报并JavaRDD的call()方法外初始化的对象(How to access objec

2019-10-21 04:14发布

我无法访问声明和JavaRDD的call()方法外初始化的对象。
在下面的代码段中,呼叫()方法使一个取来电C *但由于javaSparkContext被呼叫方法范围之外定义,以便编译器给编译错误。

stringRdd.foreach(new VoidFunction<String>() {
                @Override
                public void call(String str) throws Exception {
                    JavaRDD<String> vals = javaFunctions(javaSparkContext).cassandraTable("schema", "table", String.class)
                            .select("val");
                }
            });

在其他语言中我用封这样做,但不能够在这里实现相同。 有人建议如何在当前背景下的代码实现这一目标。

文章来源: How to access objects declared and initialized outside the call() method of JavaRDD