java如何在不连接Cassandra的情况下创建CassandraTableScanJavaRDD?
我正在尝试对连接到Cassandra并执行select语句的方法进行单元测试。然后将返回的CassandraTableScanJavaRDD转换为数据帧并进行进一步处理
对于我的单元测试,我不希望使用嵌入式cassandra。我试图用mockito模拟CassandraTableScanJavaRDD。但是我不能在里面放一些虚假的数据。 如何创建CassandraTableScanJavaRDD实例并在其中存储一些数据,而不实际连接到cassandra
# 1 楼答案
您可以尝试使用Spark Cassandra Connector Embedded——对于许多测试用例,它应该可以工作,我认为只有对于Spark流媒体作业,它可能需要真正的Cassandra
设置取决于您的软件包管理器-例如,对于SBT,它将是:
最新版本是2.4.0,但您可能需要使用其他版本,具体取决于您使用的Spark版本