org.apache.beam.sdk.transforms

Class Materializations

java.lang.Object

org.apache.beam.sdk.transforms.Materializations

@Internal
public class Materializations
extends java.lang.Object

For internal use only; no backwards-compatibility guarantees.

Utility methods for constructing known materializations for a ViewFn.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ITERABLE_MATERIALIZATION_URN The URN for a Materialization where the primitive view type is an iterable of fully specified windowed values.

Constructor Summary

Constructors

Constructor and Description
Materializations()

Method Summary

Modifier and Type	Method and Description
static <T> Materialization<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>>	iterable() For internal use only; no backwards-compatibility guarantees.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ITERABLE_MATERIALIZATION_URN

@Experimental(value=CORE_RUNNERS_ONLY)
public static final java.lang.String ITERABLE_MATERIALIZATION_URN

The URN for a Materialization where the primitive view type is an iterable of fully specified windowed values.

See Also:

Constant Field Values

Constructor Detail

Materializations

public Materializations()

Method Detail

iterable

@Internal
public static <T> Materialization<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>> iterable()

For internal use only; no backwards-compatibility guarantees.

A Materialization where the primitive view type is an iterable of fully specified windowed values.