org.apache.beam.sdk.values

Class PCollectionViews.MapViewFn<K,V>

java.lang.Object

org.apache.beam.sdk.transforms.ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,java.util.Map<K,V>>

org.apache.beam.sdk.values.PCollectionViews.MapViewFn<K,V>

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

PCollectionViews

Deprecated.

Beam views are migrating off of Iterable<WindowedValue<T>> as a primitive view type.

@Deprecated
 @Experimental(value=CORE_RUNNERS_ONLY)
public static class PCollectionViews.MapViewFn<K,V>
extends ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,java.util.Map<K,V>>

Implementation of conversion Iterable<WindowedValue<KV<K, V>> with one value per key to Map<K, V>.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MapViewFn() Deprecated.

Method Summary

Modifier and Type	Method and Description
java.util.Map<K,V>	apply(java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>> elements) Deprecated. Input iterable must actually be Iterable<WindowedValue<KV<K, V>>>.
Materialization<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>>	getMaterialization() Deprecated. Gets the materialization of this ViewFn.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapViewFn

public MapViewFn()

Deprecated.

Method Detail

getMaterialization

public Materialization<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>> getMaterialization()

Deprecated.

Description copied from class: ViewFn

Gets the materialization of this ViewFn.

Specified by:

getMaterialization in class ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,java.util.Map<K,V>>

apply

public java.util.Map<K,V> apply(java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>> elements)

Deprecated.

Input iterable must actually be Iterable<WindowedValue<KV<K, V>>>.

Specified by:

apply in class ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,java.util.Map<K,V>>