Package 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 Object

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

Method Summary

Modifier and Type	Method	Description
static <OutputT> Watch.Growth.PollResult<OutputT>	complete(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>	complete(Instant timestamp, List<OutputT> outputs)	Like complete(List), but assigns the same timestamp to all new outputs.
boolean	equals(@Nullable Object o)
int	hashCode()
static <OutputT> Watch.Growth.PollResult<OutputT>	incomplete(List<TimestampedValue<OutputT>> outputs)	Constructs a Watch.Growth.PollResult with the given outputs and declares that new outputs might appear for the current input.
static <OutputT> Watch.Growth.PollResult<OutputT>	incomplete(Instant timestamp, List<OutputT> outputs)	Like incomplete(List), but assigns the same timestamp to all new outputs.
String	toString()
Watch.Growth.PollResult<OutputT>	withOutputs(List<TimestampedValue<OutputT>> outputs)	Returns a new Watch.Growth.PollResult like this one with the provided outputs.
Watch.Growth.PollResult<OutputT>	withWatermark(Instant watermark)	Returns a new Watch.Growth.PollResult like this one with the provided watermark.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

withWatermark

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

Returns a new Watch.Growth.PollResult like this one with the provided watermark. The watermark represents an approximate lower bound on timestamps of future new outputs from the Watch.Growth.PollFn.

withOutputs

public Watch.Growth.PollResult<OutputT> withOutputs(List<TimestampedValue<OutputT>> outputs)

Returns a new Watch.Growth.PollResult like this one with the provided outputs.

toString

public String toString()

Overrides:

toString in class Object

complete

public static <OutputT>
Watch.Growth.PollResult<OutputT> complete(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,
 List<OutputT> outputs)

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

incomplete

public static <OutputT>
Watch.Growth.PollResult<OutputT> incomplete(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,
 List<OutputT> outputs)

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

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object