org.apache.beam.sdk.values

Class PCollectionViews.MultimapViewFn<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

PCollectionViews

@Experimental(value=CORE_RUNNERS_ONLY)
public static class PCollectionViews.MultimapViewFn<K,V>
extends ViewFn<Materializations.MultimapView<java.lang.Void,KV<K,V>>,java.util.Map<K,java.lang.Iterable<V>>>

Implementation which is able to adapt a multimap materialization to a Map<K, Iterable<V>>.

For internal use only.

Instantiate via PCollectionViews.multimapView(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Void, org.apache.beam.sdk.values.KV<K, V>>>, org.apache.beam.sdk.values.WindowingStrategy<?, W>).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MultimapViewFn()

Method Summary

Modifier and Type	Method and Description
java.util.Map<K,java.lang.Iterable<V>>	apply(Materializations.MultimapView<java.lang.Void,KV<K,V>> primitiveViewT) A function to adapt a primitive view type to a desired view type.
Materialization<Materializations.MultimapView<java.lang.Void,KV<K,V>>>	getMaterialization() 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

MultimapViewFn

public MultimapViewFn()

Method Detail

getMaterialization

public Materialization<Materializations.MultimapView<java.lang.Void,KV<K,V>>> getMaterialization()

Description copied from class: ViewFn

Gets the materialization of this ViewFn.

Specified by:

getMaterialization in class ViewFn<Materializations.MultimapView<java.lang.Void,KV<K,V>>,java.util.Map<K,java.lang.Iterable<V>>>

apply

public java.util.Map<K,java.lang.Iterable<V>> apply(Materializations.MultimapView<java.lang.Void,KV<K,V>> primitiveViewT)

Description copied from class: ViewFn

A function to adapt a primitive view type to a desired view type.

Specified by:

apply in class ViewFn<Materializations.MultimapView<java.lang.Void,KV<K,V>>,java.util.Map<K,java.lang.Iterable<V>>>