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.


이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.