org.apache.beam.sdk.testing

Interface StreamingIT

Deprecated.

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