org.apache.beam.sdk.transforms

Class Watch.Growth.PollResult<OutputT>

java.lang.Object

org.apache.beam.sdk.transforms.Watch.Growth.PollResult<OutputT>

Enclosing class:

Watch.Growth<InputT,OutputT,KeyT>

public static final class Watch.Growth.PollResult<OutputT>
extends java.lang.Object

The result of a single invocation of a Watch.Growth.PollFn.

Method Summary

Modifier and Type	Method and Description
static <OutputT> Watch.Growth.PollResult<OutputT>	complete(Instant timestamp, java.util.List<OutputT> outputs) Like complete(List), but assigns the same timestamp to all new outputs.
static <OutputT> Watch.Growth.PollResult<OutputT>	complete(java.util.List<TimestampedValue<OutputT>> outputs) Constructs a Watch.Growth.PollResult with the given outputs and declares that there will be no new outputs for the current input.
static <OutputT> Watch.Growth.PollResult<OutputT>	incomplete(Instant timestamp, java.util.List<OutputT> outputs) Like incomplete(List), but assigns the same timestamp to all new outputs.
static <OutputT> Watch.Growth.PollResult<OutputT>	incomplete(java.util.List<TimestampedValue<OutputT>> outputs) Constructs a Watch.Growth.PollResult with the given outputs and declares that new outputs might appear for the current input.
Watch.Growth.PollResult<OutputT>	withWatermark(Instant watermark) Sets the watermark - an approximate lower bound on timestamps of future new outputs from this Watch.Growth.PollFn.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withWatermark

public Watch.Growth.PollResult<OutputT> withWatermark(Instant watermark)

Sets the watermark - an approximate lower bound on timestamps of future new outputs from this Watch.Growth.PollFn.

complete

public static <OutputT> Watch.Growth.PollResult<OutputT> complete(java.util.List<TimestampedValue<OutputT>> outputs)

Constructs a Watch.Growth.PollResult with the given outputs and declares that there will be no new outputs for the current input. The Watch.Growth.PollFn will not be called again for this input.

complete

public static <OutputT> Watch.Growth.PollResult<OutputT> complete(Instant timestamp,
                                                                  java.util.List<OutputT> outputs)

Like complete(List), but assigns the same timestamp to all new outputs.

incomplete

public static <OutputT> Watch.Growth.PollResult<OutputT> incomplete(java.util.List<TimestampedValue<OutputT>> outputs)

Constructs a Watch.Growth.PollResult with the given outputs and declares that new outputs might appear for the current input. By default, Watch will estimate the watermark for future new outputs as equal to the earliest of the new outputs from this Watch.Growth.PollResult. To specify a more exact watermark, use withWatermark(Instant).

incomplete

public static <OutputT> Watch.Growth.PollResult<OutputT> incomplete(Instant timestamp,
                                                                    java.util.List<OutputT> outputs)

Like incomplete(List), but assigns the same timestamp to all new outputs.