在哪里可以找到 JavaMapWithStateSuite.java 中引用的 JavaTestUtils 和 BatchCounter 依赖项？

Question

我找到了这个 java 类 https://github.com/apache/spark/blob/master/streaming/src/test/java/org/apache/spark/streaming/JavaMapWithStateSuite.java，我想在它上面运行 JUNIT 测试以熟悉 Spark 状态。

但是，当我尝试将此 Java 类放入 IDE 中的新项目时，它无法解析这两个类（可能是 Java？）：

• JavaTestUtils
• 批次计数器

在哪里可以找到这些类来运行这些 JUNIT 测试？

Answer 1

不，（不幸的是！？；）不是 java：

• JavaTestUtils.scala
• 和 BatchCounter 在TestSuiteBase.scala 中定义

---