Package org.apache.beam.sdk.testing

Interface StreamingIT

@Deprecated
public 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.

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