Package org.apache.beam.sdk.testing
Interface UsesTestStreamWithProcessingTime
-
- All Superinterfaces:
UsesTestStream
,UsesUnboundedPCollections
@Internal public interface UsesTestStreamWithProcessingTime extends UsesTestStream
Subcategory forUsesTestStream
tests which use the processing time feature ofTestStream
. Some Runners do not support setting processing time globally in a way thatTestStream
demands it.