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 java.lang.Object
The result of a single invocation of aWatch.Growth.PollFn
.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <OutputT> Watch.Growth.PollResult<OutputT>
complete(java.util.List<TimestampedValue<OutputT>> outputs)
Constructs aWatch.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(org.joda.time.Instant timestamp, java.util.List<OutputT> outputs)
Likecomplete(List)
, but assigns the same timestamp to all new outputs.boolean
equals(@Nullable java.lang.Object o)
int
hashCode()
static <OutputT> Watch.Growth.PollResult<OutputT>
incomplete(java.util.List<TimestampedValue<OutputT>> outputs)
Constructs aWatch.Growth.PollResult
with the given outputs and declares that new outputs might appear for the current input.static <OutputT> Watch.Growth.PollResult<OutputT>
incomplete(org.joda.time.Instant timestamp, java.util.List<OutputT> outputs)
Likeincomplete(List)
, but assigns the same timestamp to all new outputs.java.lang.String
toString()
Watch.Growth.PollResult<OutputT>
withOutputs(java.util.List<TimestampedValue<OutputT>> outputs)
Returns a newWatch.Growth.PollResult
like this one with the provided outputs.Watch.Growth.PollResult<OutputT>
withWatermark(org.joda.time.Instant watermark)
Returns a newWatch.Growth.PollResult
like this one with the provided watermark.
-
-
-
Method Detail
-
withWatermark
public Watch.Growth.PollResult<OutputT> withWatermark(org.joda.time.Instant watermark)
Returns a newWatch.Growth.PollResult
like this one with the provided watermark. The watermark represents an approximate lower bound on timestamps of future new outputs from theWatch.Growth.PollFn
.
-
withOutputs
public Watch.Growth.PollResult<OutputT> withOutputs(java.util.List<TimestampedValue<OutputT>> outputs)
Returns a newWatch.Growth.PollResult
like this one with the provided outputs.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
complete
public static <OutputT> Watch.Growth.PollResult<OutputT> complete(java.util.List<TimestampedValue<OutputT>> outputs)
Constructs aWatch.Growth.PollResult
with the given outputs and declares that there will be no new outputs for the current input. TheWatch.Growth.PollFn
will not be called again for this input.
-
complete
public static <OutputT> Watch.Growth.PollResult<OutputT> complete(org.joda.time.Instant timestamp, java.util.List<OutputT> outputs)
Likecomplete(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 aWatch.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 thisWatch.Growth.PollResult
. To specify a more exact watermark, usewithWatermark(Instant)
.
-
incomplete
public static <OutputT> Watch.Growth.PollResult<OutputT> incomplete(org.joda.time.Instant timestamp, java.util.List<OutputT> outputs)
Likeincomplete(List)
, but assigns the same timestamp to all new outputs.
-
equals
public boolean equals(@Nullable java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
-