Package org.apache.beam.sdk.testing
Interface UsesTestStreamWithMultipleStages
-
- All Superinterfaces:
UsesTestStream
,UsesUnboundedPCollections
@Internal public interface UsesTestStreamWithMultipleStages extends UsesTestStream
Subcategory forUsesTestStream
tests which useTestStream
# across multiple stages. Some Runners do not properly support quiescence in a way thatTestStream
demands it.