TestStream.Builder (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.testing

Class TestStream.Builder<T>

  • Enclosing class:
    TestStream<T>


    public static class TestStream.Builder<T>
    extends Object
    An incomplete TestStream. Elements added to this builder will be produced in sequence when the pipeline created by the TestStream is run.
    • Method Detail

      • addElements

        @SafeVarargs
        public final TestStream.Builder<T> addElements(T first,
                                                                    T... rest)
        Adds the specified elements to the source with timestamp equal to the current watermark.
        Returns:
        A TestStream.Builder like this one that will emit the provided elements after all earlier events have completed.
      • advanceWatermarkTo

        public TestStream.Builder<T> advanceWatermarkTo(Instant newWatermark)
        Advance the watermark of this source to the specified instant.

        The watermark must advance monotonically and cannot advance to BoundedWindow.TIMESTAMP_MAX_VALUE or beyond.

        Returns:
        A TestStream.Builder like this one that will advance the watermark to the specified point after all earlier events have completed.
      • advanceProcessingTime

        public TestStream.Builder<T> advanceProcessingTime(Duration amount)
        Advance the processing time by the specified amount.
        Returns:
        A TestStream.Builder like this one that will advance the processing time by the specified amount after all earlier events have completed.
      • advanceWatermarkToInfinity

        public TestStream<T> advanceWatermarkToInfinity()
        Advance the watermark to infinity, completing this TestStream. Future calls to the same builder will not affect the returned TestStream.


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Dataflow