Package org.apache.beam.sdk.testing
Interface StreamingIT
-
@Deprecated public interface StreamingIT
Deprecated.tests which use unbounded PCollections should be in the categoryUsesUnboundedPCollections
. Beyond that, it is up to the runner and test configuration to decide whether to run in streaming mode.Category tag used to mark tests which execute in streaming mode. Example usage:@Test @Category(StreamingIT.class) public void testStreamingPipeline() { StreamingOptions options = ...; options.setStreaming(true); StreamingPipeline.main(...); }