Package org.apache.beam.sdk.transforms

Class Materializations

java.lang.Object

org.apache.beam.sdk.transforms.Materializations

@Internal
public class Materializations
extends Object

For internal use only; no backwards-compatibility guarantees.

Utility methods for constructing known materializations for a ViewFn.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Materializations.IterableView<V>	Represents the PrimitiveViewT supplied to the ViewFn when it declares to use the iterable materialization.
static interface	Materializations.MultimapView<K,V>	Represents the PrimitiveViewT supplied to the ViewFn when it declares to use the multimap materialization.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Materializations()

Method Summary

Modifier and Type	Method	Description
static <V> Materialization<Materializations.IterableView<V>>	iterable()	For internal use only; no backwards-compatibility guarantees.
static <K, V> Materialization<Materializations.MultimapView<K,V>>	multimap()	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 Details

ITERABLE_MATERIALIZATION_URN

public static final 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

MULTIMAP_MATERIALIZATION_URN

public static final String MULTIMAP_MATERIALIZATION_URN

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

See Also:

• Constant Field Values

Constructor Details

Materializations

public Materializations()

Method Details

multimap

@Internal
public static <K,
V>
Materialization<Materializations.MultimapView<K,V>> multimap()

For internal use only; no backwards-compatibility guarantees.

A Materialization where the primitive view type is a multimap with fully specified windowed values.

iterable

@Internal
public static <V>
Materialization<Materializations.IterableView<V>> iterable()

For internal use only; no backwards-compatibility guarantees.

A Materialization where the primitive view type is an iterable with fully specifed windowed values.