How to use TestPipeline

Question

yun-cn opened this issue 4 years ago · 3 comments

@Rule public final transient TestPipeline pipeline = TestPipeline.create();

How to write this example in Junit5?
Can you give me some suggest.
Thank you.

Answer 1 · 2021-03-01T14:02:55.000Z

What's TestPipeline?

Answer 2 · 2021-03-02T00:17:00.000Z

This is Apache beam.

Answer 3 · 2021-03-02T08:29:10.000Z

Please ask at the Apache Beam project if they (plan to) provide an equivalent JUnit Jupiter extension.