在哪里可以找到 JavaMapWithStateSuite.java 中引用的 JavaTestUtils 和 BatchCounter 依赖项?
Where can I find the JavaTestUtils and BatchCounter dependencies referenced in JavaMapWithStateSuite.java?
我发现这个 java class https://github.com/apache/spark/blob/master/streaming/src/test/java/org/apache/spark/streaming/JavaMapWithStateSuite.java 我想 运行 JUNIT 测试以熟悉 Spark 状态。
但是,当我尝试将此 Java class 放入我的 IDE 中的新项目时,它无法解析这两个 classes(大概 Java?):
- JavaTestUtils
- 批量计数器
我在哪里可以找到这些 classes 到 运行 这些 JUNIT 测试?
不,(不幸的是!?;)不是 java:
- JavaTestUtils.scala
- 并且 BatchCounter 在 TestSuiteBase.scala
中定义
我发现这个 java class https://github.com/apache/spark/blob/master/streaming/src/test/java/org/apache/spark/streaming/JavaMapWithStateSuite.java 我想 运行 JUNIT 测试以熟悉 Spark 状态。
但是,当我尝试将此 Java class 放入我的 IDE 中的新项目时,它无法解析这两个 classes(大概 Java?):
- JavaTestUtils
- 批量计数器
我在哪里可以找到这些 classes 到 运行 这些 JUNIT 测试?
不,(不幸的是!?;)不是 java:
- JavaTestUtils.scala
- 并且 BatchCounter 在 TestSuiteBase.scala 中定义