Package org.apache.beam.sdk.schemas.transforms

Class Filter.Inner<T>

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollection<T>,PCollection<T>>

org.apache.beam.sdk.schemas.transforms.Filter.Inner<T>

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

Enclosing class:

Filter

public static class Filter.Inner<T>
extends PTransform<PCollection<T>,PCollection<T>>

Implementation of the filter.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

name, resourceHints

Constructor Summary

Constructors

Constructor	Description
Inner()

Method Summary

Modifier and Type	Method	Description
PCollection<T>	expand(PCollection<T> input)	Override this method to specify how this PTransform should be expanded on the given InputT.
<FieldT> Filter.Inner<T>	whereFieldId(int fieldId, SerializableFunction<FieldT,java.lang.Boolean> predicate)	Set a predicate based on the value of a field, where the field is specified by id.
Filter.Inner<T>	whereFieldIds(java.util.List<java.lang.Integer> fieldIds, SerializableFunction<Row,java.lang.Boolean> predicate)	Set a predicate based on the value of multipled fields, specified by id.
<FieldT> Filter.Inner<T>	whereFieldName(java.lang.String fieldName, SerializableFunction<FieldT,java.lang.Boolean> predicate)	Set a predicate based on the value of a field, where the field is specified by name.
Filter.Inner<T>	whereFieldNames(java.util.List<java.lang.String> fieldNames, SerializableFunction<Row,java.lang.Boolean> predicate)	Set a predicate based on the value of multipled fields, specified by name.

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Constructor Detail

Inner

public Inner()

Method Detail

whereFieldName

public <FieldT> Filter.Inner<T> whereFieldName(java.lang.String fieldName,
                                               SerializableFunction<FieldT,java.lang.Boolean> predicate)

Set a predicate based on the value of a field, where the field is specified by name.

whereFieldId

public <FieldT> Filter.Inner<T> whereFieldId(int fieldId,
                                             SerializableFunction<FieldT,java.lang.Boolean> predicate)

Set a predicate based on the value of a field, where the field is specified by id.

whereFieldNames

public Filter.Inner<T> whereFieldNames(java.util.List<java.lang.String> fieldNames,
                                       SerializableFunction<Row,java.lang.Boolean> predicate)

Set a predicate based on the value of multipled fields, specified by name.

whereFieldIds

public Filter.Inner<T> whereFieldIds(java.util.List<java.lang.Integer> fieldIds,
                                     SerializableFunction<Row,java.lang.Boolean> predicate)

Set a predicate based on the value of multipled fields, specified by id.

expand

public PCollection<T> expand(PCollection<T> input)

Description copied from class: PTransform

Override this method to specify how this PTransform should be expanded on the given InputT.

NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

Specified by:

expand in class PTransform<PCollection<T>,PCollection<T>>