From ab5b24b5540308dce69743cddc5c2ecd89541393 Mon Sep 17 00:00:00 2001 From: Derrick Williams Date: Fri, 30 May 2025 20:14:50 +0000 Subject: [PATCH] update test your pipeline with TestPipeline with Rule --- .../content/en/documentation/pipelines/test-your-pipeline.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/website/www/site/content/en/documentation/pipelines/test-your-pipeline.md b/website/www/site/content/en/documentation/pipelines/test-your-pipeline.md index 82f5e33ed07a..512b58735ac9 100644 --- a/website/www/site/content/en/documentation/pipelines/test-your-pipeline.md +++ b/website/www/site/content/en/documentation/pipelines/test-your-pipeline.md @@ -287,6 +287,8 @@ The following example code shows how one might test the [WordCount example pipel {{< highlight java >}} public class WordCountTest { + @Rule public final transient TestPipeline p = TestPipeline.create(); + // Our static input data, which will comprise the initial PCollection. static final String[] WORDS_ARRAY = new String[] { "hi there", "hi", "hi sue bob", @@ -301,8 +303,6 @@ public class WordCountTest { // Example test that tests the pipeline's transforms. public void testCountWords() throws Exception { - Pipeline p = TestPipeline.create(); - // Create a PCollection from the WORDS static input data. PCollection input = p.apply(Create.of(WORDS));