Reify (Apache Beam 2.18.0)

java.lang.Object
- org.apache.beam.sdk.transforms.Reify

```
public class Reify
extends java.lang.Object
```
PTransforms for converting between explicit and implicit form of various Beam values.

Method Summary

All Methods Static Methods Concrete Methods
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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

timestamps

public static <T> PTransform<PCollection<T>,PCollection<TimestampedValue<T>>> timestamps()

Create a PTransform that will output all inputs wrapped in a TimestampedValue.

timestampsInValue

public 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.

windows
```
public static <T> PTransform<PCollection<T>,PCollection<ValueInSingleWindow<T>>> windows()
```
Create a PTransform that will reify information from the processing context into instances of ValueInSingleWindow.

Type Parameters:

T - element type

windowsInValue

public 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.

extractTimestampsFromValues

public static <K,V> PTransform<PCollection<KV<K,TimestampedValue<V>>>,PCollection<KV<K,V>>> extractTimestampsFromValues()

Extracts the timestamps from each value in a KV.

viewAsValues

public 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.

viewInGlobalWindow

public 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.

Class Reify