org.apache.beam.sdk.testing

Interface StreamingIT

Deprecated.

tests which use unbounded PCollections should be in the category UsesUnboundedPCollections. Beyond that, it is up to the runner and test configuration to decide whether to run in streaming mode.

@Deprecated
public interface StreamingIT

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(...);
     }