java - 如何在Spark中使用RowReaderFactory

我正在尝试从cassandra表中获取键值pairRDD。
乍一看，我遇到了一个看起来非常不错的类：RowReaderFactory

RowReaderFactory<Dog> dogRRF = new RowReaderDogFactory();
RowReaderFactory<Owner> ownerRRF = new RowReaderOwnerFactory();
JavaPairRDD<Owner, Dog> indexPairRDD = functions.cassandraTable(keyspace, "dog", ownerRRF, dogRRF);

用我的RowReaderFactory这样定义（与所有者相同）

public class RowReaderDogFactory implements RowReaderFactory<Dog> {

    @Override
    public RowReader<Dog> rowReader(TableDef arg0, RowReaderOptions arg1) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public RowReaderOptions rowReader$default$2() {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Class<Dog> targetClass() {
        // TODO Auto-generated method stub
        return null;
    }

}

我不知道如何使用此RowReaderFactory类。

运行此程序时，我显然得到了一个nullPointer ...而且我在互联网上找不到有关示例的任何解释。

任何帮助，将不胜感激 ！

提前致谢

最佳答案

链接Spark RowReaderFactory中显示的示例将为您提供帮助。我没有详细看写我的理解。但是，boneill42（对不起，如果我拼错了这个名字。我可以找到它作为作者的用户名。）提供了完整的工作示例，有助于调试。

当我从Spark SQL寻找一些Spark SQL东西时，我提到了这一点。这也仅供参考。