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 use TestStream, 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).