Package google.registry.beam.common

Class RegistryJpaIO.Read<R,T>

java.lang.Object

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

google.registry.beam.common.RegistryJpaIO.Read<R,T>

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

RegistryJpaIO

public abstract static class RegistryJpaIO.Read<R,T>
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<T>>

A transform that transactionally executes a JPA CriteriaQuery and adds the results to the BEAM pipeline. Users have the option to transform the results before sending them to the next stages.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RegistryJpaIO.Read.Builder<R,T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_NAME

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

annotations, displayData, name, resourceHints

Constructor Summary

Constructors

Constructor	Description
Read()

Method Summary

Modifier and Type	Method	Description
org.apache.beam.sdk.values.PCollection<T>	expand(org.apache.beam.sdk.values.PBegin input)
RegistryJpaIO.Read<R,T>	withCoder(org.apache.beam.sdk.coders.Coder<T> coder)
RegistryJpaIO.Read<R,T>	withName(String name)
RegistryJpaIO.Read<R,T>	withResultMapper(org.apache.beam.sdk.transforms.SerializableFunction<R,T> mapper)

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

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_NAME

public static final String DEFAULT_NAME

See Also:

• Constant Field Values

Constructor Details

Read

public Read()

Method Details

expand

public org.apache.beam.sdk.values.PCollection<T> expand(org.apache.beam.sdk.values.PBegin input)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<T>>

withName

public RegistryJpaIO.Read<R,T> withName(String name)

withResultMapper

public RegistryJpaIO.Read<R,T> withResultMapper(org.apache.beam.sdk.transforms.SerializableFunction<R,T> mapper)

withCoder

public RegistryJpaIO.Read<R,T> withCoder(org.apache.beam.sdk.coders.Coder<T> coder)