Package org.apache.beam.sdk.testing
Interface UsesTestStream
-
- All Superinterfaces:
UsesUnboundedPCollections
- All Known Subinterfaces:
UsesTestStreamWithMultipleStages
,UsesTestStreamWithOutputTimestamp
,UsesTestStreamWithProcessingTime
@Internal public interface UsesTestStream extends UsesUnboundedPCollections
Category tag for tests that useTestStream
, which is not a part of the Beam model but a special feature currently only implemented by the direct runner and the Flink Runner (streaming).