| // Copyright 2022 Google LLC |
| // |
| // Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or |
| // https://www.apache.org/licenses/LICENSE-2.0> or the MIT license |
| // <LICENSE-MIT or https://opensource.org/licenses/MIT>, at your |
| // option. This file may not be copied, modified, or distributed |
| // except according to those terms. |
| |
| package com.example; |
| |
| import org.apache.beam.sdk.Pipeline; |
| import org.apache.beam.sdk.testing.PAssert; |
| import org.apache.beam.sdk.testing.TestPipeline; |
| import org.junit.Rule; |
| import org.junit.Test; |
| import org.junit.runner.RunWith; |
| import org.junit.runners.JUnit4; |
| |
| @RunWith(JUnit4.class) |
| public class AppTest { |
| @Rule |
| public final transient TestPipeline pipeline = TestPipeline.create(); |
| |
| @Test |
| public void appRuns() { |
| var elements = App.buildPipeline(pipeline, "Test"); |
| |
| // Note that the order of the elements doesn't matter. |
| PAssert.that(elements).containsInAnyOrder("Test", "Hello", "World!"); |
| pipeline.run().waitUntilFinish(); |
| } |
| } |