单元测试采用侧面输入的数据流/apache 光束管道

Question

使用 Dataflow 2.1 sdk

        <dependency>
            <groupId>com.google.cloud.dataflow</groupId>
            <artifactId>google-cloud-dataflow-java-sdk-all</artifactId>
            <version>[2.1.0, 2.99)</version>
        </dependency>

根据this 文档setSideInputInGlobalWindow 应该可用。但我只看到以下两个相关功能：

下面是我的完整代码：

DoFnTester<EventItem,EventItem> fnTester = DoFnTester.of(myDoFn);
    TestPipeline pipeline = TestPipeline.create();

TableRow row= new TableRow();
        atr.set("a", 7);
        atr.set("q", new ArrayList<String>() {{ add("video_referrer"); add("from_homepage");}});

PCollectionView<TableRow> sideInput =  (PCollectionView<TableRow>) pipeline.apply(Create.of(Arrays.asList(atr)));
        Iterable<TableRow> sidVal = Arrays.asList(atr);
        fnTester.setSideInput(sideInput, sidVal); //error on this line

        List<Foo> testOutputs = fnTester.processBundle(Arrays.asList(testInput));

我看到setSideInput(PCollectionView<T> sideInput, BoundedWindow window, T value) 函数here。但在这种情况下，我如何获得BoundedWindow 任何想法我在这里缺少什么，谢谢。

Answer 1

您可以尝试使用 GlobalWindow.INSTANCE 但通常 DoFnTester 将被弃用，推荐的方法是始终使用 TestPipeline 和 PAssert。