我无法访问声明和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");
}
});
在其他语言中我用封这样做,但不能够在这里实现相同。 有人建议如何在当前背景下的代码实现这一目标。