getAs () - Миграция Apache Spark 1.6.3 в Apache Spark 2.2.0

Question

Я недавно мигрировал с Apache Spark 1.6.3 до версии 2.2.0, и у меня есть некоторые проблемы с некоторыми функциями, которые изменились

в SPARK 1.6.3 я делаю так,

КОД НАХОДИТСЯ В JAVA

    List<String[]> list_id_fk = dfHBaseTemp.toJavaRDD().map(l -> {
            String[] arrayListFK = {"", ""};
            arrayListFK[0] = l.getAs("ID_KEY");
            arrayListFK[1] = l.getAs("ID_TW");
            //System.out.println(arrayListFK[0] +" "+ arrayListFK[1]);
            return arrayListFK;
        }).collect();

THE .getAs("ID_KEY"); не является допустимым методом в версии 2.2.0 !!

Теперь в SPAKR 2.2.0 я должен делать?

Спасибо!