Wie setze und erhalte ich statische Variablen von spark?
Ich habe eine Klasse wie diese:
public class Test {
private static String name;
public static String getName() {
return name;
}
public static void setName(String name) {
Test.name = name;
}
public static void print() {
System.out.println(name);
}
}
in meinem Spark-Treiber stelle ich den Namen so ein und rufe das @ aprint()
Befehl
public final class TestDriver{
public static void main(String[] args) throws Exception {
SparkConf sparkConf = new SparkConf().setAppName("TestApp");
// ...
// ...
Test.setName("TestName")
Test.print();
// ...
}
}
Allerdings bekomme ich einNullPointerException
. Wie übergebe ich einen Wert an die globale Variable und verwende ihn?