java - 从没有 SparkContext 的列表创建 JavaRDD

标签 java unit-testing junit apache-spark

我正在围绕 Spark 项目编写一些 JUnit 单元测试。

我尝试测试的函数之一接受 JavaRDD 作为参数,我想以编程方式创建该 JavaRDD,并且从列表转换为 RDD 似乎是最合乎逻辑的方法。

How to convert List to JavaRDD建议我使用JavaSparkContext.parallelize(List) 。但是,由于我是在单元测试中执行此操作,因此我不想实例化 SparkContext 对象。

最佳答案

这并不是一个真正的选择,您需要使用 Spark Context 来创建 RDD。一种选择是使用 spark-testing-base (它也在 spark packages )(我是作者)创建用于测试用途的 Spark 上下文。如果它有帮助,我可以扩展它以提供一个也提供 JavaSparkContext 的基类吗?

关于java - 从没有 SparkContext 的列表创建 JavaRDD,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30494686/

相关文章:

java - 使用hamcrest匹配Map包含不同类型的条目

java - 无缝地将数组和列表传入和传出 Nashorn

java - Jsoup Java doc.select 雅虎财经

java - JFrame 不显示 JPanel 和 Java 中的其他小部件

java - 为什么用PowerMockRunner运行时不能使用@InjectMocks字段匹配?

java - 如何使用 Jmockit 模拟 JdbcTemplate.update?

spring - 使用 Maven/JUnit/Spring 在第一次失败时停止测试

java - 手指在屏幕上滑动的灵敏度

unit-testing - 良好的边境测试

java - 在 Qpid 上调用的 RabbitMQ Java API queuePurge() 方法返回消息计数为零的 PurgeOK 响应