Package org.apache.beam.runners.spark.translation

Class TranslationUtils.TupleTagFilter<V>

java.lang.Object

org.apache.beam.runners.spark.translation.TranslationUtils.TupleTagFilter<V>

Type Parameters:

V - TupleTag type.

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function<scala.Tuple2<org.apache.beam.sdk.values.TupleTag<V>,org.apache.beam.sdk.values.WindowedValue<?>>,Boolean>

Enclosing class:

TranslationUtils

public static final class TranslationUtils.TupleTagFilter<V>
extends Object
implements org.apache.spark.api.java.function.Function<scala.Tuple2<org.apache.beam.sdk.values.TupleTag<V>,org.apache.beam.sdk.values.WindowedValue<?>>,Boolean>

A utility class to filter TupleTags.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
TupleTagFilter(org.apache.beam.sdk.values.TupleTag<V> tag)

Method Summary

Modifier and Type	Method	Description
Boolean	call(scala.Tuple2<org.apache.beam.sdk.values.TupleTag<V>,org.apache.beam.sdk.values.WindowedValue<?>> input)

Methods inherited from class java.lang.Object

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

Constructor Details

TupleTagFilter

public TupleTagFilter(org.apache.beam.sdk.values.TupleTag<V> tag)

Method Details

call

public Boolean call(scala.Tuple2<org.apache.beam.sdk.values.TupleTag<V>,org.apache.beam.sdk.values.WindowedValue<?>> input)

Specified by:

call in interface org.apache.spark.api.java.function.Function<scala.Tuple2<org.apache.beam.sdk.values.TupleTag<V>,org.apache.beam.sdk.values.WindowedValue<?>>,Boolean>