public class Reify
extends java.lang.Object
PTransforms
for converting between explicit and implicit form of various Beam
values.Modifier and Type | Method and Description |
---|---|
static <K,V> PTransform<PCollection<KV<K,TimestampedValue<V>>>,PCollection<KV<K,V>>> |
extractTimestampsFromValues()
Extracts the timestamps from each value in a
KV . |
static <T> PTransform<PCollection<T>,PCollection<TimestampedValue<T>>> |
timestamps()
Create a
PTransform that will output all inputs wrapped in a TimestampedValue . |
static <K,V> PTransform<PCollection<KV<K,V>>,PCollection<KV<K,TimestampedValue<V>>>> |
timestampsInValue()
Create a
PTransform that will output all input KVs with the timestamp inside
the value. |
static <K,V> PTransform<PCollection<K>,PCollection<KV<K,V>>> |
viewAsValues(PCollectionView<V> view,
Coder<V> coder)
Pairs each element in a collection with the value of a side input associated with the element's
window.
|
static <K,V> PTransform<PBegin,PCollection<V>> |
viewInGlobalWindow(PCollectionView<V> view,
Coder<V> coder)
Returns a
PCollection consisting of a single element, containing the value of the given
view in the global window. |
static <T> PTransform<PCollection<T>,PCollection<ValueInSingleWindow<T>>> |
windows()
Create a
PTransform that will reify information from the processing context into
instances of ValueInSingleWindow . |
static <K,V> PTransform<PCollection<KV<K,V>>,PCollection<KV<K,ValueInSingleWindow<V>>>> |
windowsInValue()
Create a
PTransform that will output all input KVs with the window pane info
inside the value. |
public static <T> PTransform<PCollection<T>,PCollection<TimestampedValue<T>>> timestamps()
PTransform
that will output all inputs wrapped in a TimestampedValue
.public static <K,V> PTransform<PCollection<KV<K,V>>,PCollection<KV<K,TimestampedValue<V>>>> timestampsInValue()
PTransform
that will output all input KVs
with the timestamp inside
the value.public static <T> PTransform<PCollection<T>,PCollection<ValueInSingleWindow<T>>> windows()
PTransform
that will reify information from the processing context into
instances of ValueInSingleWindow
.T
- element typepublic static <K,V> PTransform<PCollection<KV<K,V>>,PCollection<KV<K,ValueInSingleWindow<V>>>> windowsInValue()
PTransform
that will output all input KVs
with the window pane info
inside the value.public static <K,V> PTransform<PCollection<KV<K,TimestampedValue<V>>>,PCollection<KV<K,V>>> extractTimestampsFromValues()
KV
.public static <K,V> PTransform<PCollection<K>,PCollection<KV<K,V>>> viewAsValues(PCollectionView<V> view, Coder<V> coder)
public static <K,V> PTransform<PBegin,PCollection<V>> viewInGlobalWindow(PCollectionView<V> view, Coder<V> coder)
PCollection
consisting of a single element, containing the value of the given
view in the global window.