org.apache.beam.sdk.testing

Interface UsesTestStreamWithProcessingTime

All Superinterfaces:

UsesTestStream

@Internal
public interface UsesTestStreamWithProcessingTime
extends UsesTestStream

Subcategory for UsesTestStream tests which use the processing time feature of TestStream. Some Runners do not support setting processing time globally in a way that TestStream demands it.