V - the type of the valuepublic abstract class WindowedValue<V> extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
WindowedValue.FullWindowedValueCoder<T>
Coder for
WindowedValue. |
static class |
WindowedValue.ValueOnlyWindowedValueCoder<T>
Coder for
WindowedValue. |
static class |
WindowedValue.WindowedValueCoder<T>
Abstract class for
WindowedValue coder. |
| Modifier and Type | Field and Description |
|---|---|
protected PaneInfo |
pane |
protected V |
value |
| Modifier and Type | Method and Description |
|---|---|
abstract boolean |
equals(Object o) |
static <T> WindowedValue.FullWindowedValueCoder<T> |
getFullCoder(Coder<T> valueCoder,
Coder<? extends BoundedWindow> windowCoder)
Returns the
Coder to use for a WindowedValue<T>,
using the given valueCoder and windowCoder. |
PaneInfo |
getPane()
Returns the pane of this
WindowedValue in its window. |
abstract org.joda.time.Instant |
getTimestamp()
Returns the timestamp of this
WindowedValue. |
V |
getValue()
Returns the value of this
WindowedValue. |
static <T> WindowedValue.ValueOnlyWindowedValueCoder<T> |
getValueOnlyCoder(Coder<T> valueCoder)
Returns the
ValueOnlyCoder from the given valueCoder. |
abstract Collection<? extends BoundedWindow> |
getWindows()
Returns the windows of this
WindowedValue. |
abstract int |
hashCode() |
static <V> WindowedValue<V> |
of(V value,
org.joda.time.Instant timestamp,
BoundedWindow window,
PaneInfo pane)
Returns a
WindowedValue with the given value, timestamp, and window. |
static <V> WindowedValue<V> |
of(V value,
org.joda.time.Instant timestamp,
Collection<? extends BoundedWindow> windows,
PaneInfo pane)
Returns a
WindowedValue with the given value, timestamp,
and windows. |
static <V> WindowedValue<V> |
timestampedValueInGlobalWindow(V value,
org.joda.time.Instant timestamp)
Returns a
WindowedValue with the given value and timestamp,
GlobalWindow and default pane. |
abstract String |
toString() |
static <V> WindowedValue<V> |
valueInEmptyWindows(V value)
Returns a
WindowedValue with the given value in no windows, and the default timestamp
and pane. |
static <V> WindowedValue<V> |
valueInEmptyWindows(V value,
PaneInfo pane)
Returns a
WindowedValue with the given value in no windows, and the default timestamp
and the specified pane. |
static <V> WindowedValue<V> |
valueInGlobalWindow(V value)
Returns a
WindowedValue with the given value in the GlobalWindow using the
default timestamp and pane. |
static <V> WindowedValue<V> |
valueInGlobalWindow(V value,
PaneInfo pane)
Returns a
WindowedValue with the given value in the GlobalWindow using the
default timestamp and the specified pane. |
abstract <V> WindowedValue<V> |
withValue(V value)
Returns a new
WindowedValue that is a copy of this one,
but with a different value. |
public static <V> WindowedValue<V> of(V value, org.joda.time.Instant timestamp, Collection<? extends BoundedWindow> windows, PaneInfo pane)
WindowedValue with the given value, timestamp,
and windows.public static <V> WindowedValue<V> of(V value, org.joda.time.Instant timestamp, BoundedWindow window, PaneInfo pane)
WindowedValue with the given value, timestamp, and window.public static <V> WindowedValue<V> valueInGlobalWindow(V value)
WindowedValue with the given value in the GlobalWindow using the
default timestamp and pane.public static <V> WindowedValue<V> valueInGlobalWindow(V value, PaneInfo pane)
WindowedValue with the given value in the GlobalWindow using the
default timestamp and the specified pane.public static <V> WindowedValue<V> timestampedValueInGlobalWindow(V value, org.joda.time.Instant timestamp)
WindowedValue with the given value and timestamp,
GlobalWindow and default pane.public static <V> WindowedValue<V> valueInEmptyWindows(V value)
WindowedValue with the given value in no windows, and the default timestamp
and pane.public static <V> WindowedValue<V> valueInEmptyWindows(V value, PaneInfo pane)
WindowedValue with the given value in no windows, and the default timestamp
and the specified pane.public abstract <V> WindowedValue<V> withValue(V value)
WindowedValue that is a copy of this one,
but with a different value.public V getValue()
WindowedValue.public abstract org.joda.time.Instant getTimestamp()
WindowedValue.public abstract Collection<? extends BoundedWindow> getWindows()
WindowedValue.public PaneInfo getPane()
WindowedValue in its window.public static <T> WindowedValue.FullWindowedValueCoder<T> getFullCoder(Coder<T> valueCoder, Coder<? extends BoundedWindow> windowCoder)
Coder to use for a WindowedValue<T>,
using the given valueCoder and windowCoder.public static <T> WindowedValue.ValueOnlyWindowedValueCoder<T> getValueOnlyCoder(Coder<T> valueCoder)
ValueOnlyCoder from the given valueCoder.