Package org.apache.beam.sdk.transforms

Class Reify

java.lang.Object

org.apache.beam.sdk.transforms.Reify

public class Reify
extends Object

PTransforms for converting between explicit and implicit form of various Beam values.

Method Summary

Modifier and Type	Method	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 Details

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.