有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java如何在不连接Cassandra的情况下创建CassandraTableScanJavaRDD?

我正在尝试对连接到Cassandra并执行select语句的方法进行单元测试。然后将返回的CassandraTableScanJavaRDD转换为数据帧并进行进一步处理

对于我的单元测试,我不希望使用嵌入式cassandra。我试图用mockito模拟CassandraTableScanJavaRDD。但是我不能在里面放一些虚假的数据。 如何创建CassandraTableScanJavaRDD实例并在其中存储一些数据,而不实际连接到cassandra


共 (1) 个答案

  1. # 1 楼答案

    您可以尝试使用Spark Cassandra Connector Embedded——对于许多测试用例,它应该可以工作,我认为只有对于Spark流媒体作业,它可能需要真正的Cassandra

    设置取决于您的软件包管理器-例如,对于SBT,它将是:

    "com.datastax.spark"  %% "spark-cassandra-connector-embedded" % {version}
    

    最新版本是2.4.0,但您可能需要使用其他版本,具体取决于您使用的Spark版本