org.apache.beam.sdk.testing

Interface UsesTestStreamWithMultipleStages

All Superinterfaces:

UsesTestStream

@Internal
public interface UsesTestStreamWithMultipleStages
extends UsesTestStream

Subcategory for UsesTestStream tests which use TestStream # across multiple stages. Some Runners do not properly support quiescence in a way that TestStream demands it.