org.apache.beam.sdk.values

Class PCollectionViews.SingletonViewFn<T>

java.lang.Object

org.apache.beam.sdk.transforms.ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>,T>

org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn<T>

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.SingletonViewFn<T>
extends ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>,T>

Implementation of conversion of singleton Iterable<WindowedValue<T>> to T.

For internal use only.

Instantiate via PCollectionViews.singletonView(org.apache.beam.sdk.values.PCollection<T>, org.apache.beam.sdk.values.WindowingStrategy<?, W>, boolean, T, org.apache.beam.sdk.coders.Coder<T>).

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
T	apply(java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>> contents) Deprecated. A function to adapt a primitive view type to a desired view type.
T	getDefaultValue() Deprecated. Returns the default value that was specified.
Materialization<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>>	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

Method Detail

getDefaultValue

public T getDefaultValue()

Deprecated.

Returns the default value that was specified.

For internal use only.

Throws:

java.util.NoSuchElementException - if no default was specified.

getMaterialization

public Materialization<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>> 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<T>>,T>

apply

public T apply(java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>> contents)

Deprecated.

Description copied from class: ViewFn

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

Specified by:

apply in class ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>,T>