PAssert

Javadoc Javadoc


PAssert 是 Beam Java SDK 中的一个类，它对 PCollection 的内容进行断言。您可以使用 PAssert 来验证 PCollection 是否包含一组特定的预期元素。

示例

对于给定的 PCollection，您可以使用 PAssert 来验证内容，如下所示

PCollection<String> output = ...;

// Check whether a PCollection contains some elements in any order.
PAssert.that(output)
.containsInAnyOrder(
  "elem1",
  "elem3",
  "elem2");

任何使用 PAssert 的代码都必须链接 JUnit 和 Hamcrest。如果您使用的是 Maven，可以通过在项目的 pom.xml 文件中添加以下依赖项来链接 Hamcrest

<dependency>
    <groupId>org.hamcrest</groupId>
    <artifactId>hamcrest-all</artifactId>
    <version>1.3</version>
    <scope>test</scope>
</dependency>