Package google.registry.beam.common

Class RegistryJpaIO.Read<R,​T>

  • All Implemented Interfaces:
    java.io.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

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static java.lang.String DEFAULT_NAME  

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

        name, resourceHints

    • Constructor Summary

      Constructors 
      Constructor Description
      Read()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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​(java.lang.String name)  
      RegistryJpaIO.Read<R,​T> withResultMapper​(org.apache.beam.sdk.transforms.SerializableFunction<R,​T> mapper)  
      RegistryJpaIO.Read<R,​T> withSnapshot​(java.lang.String snapshotId)
      Specifies the database snapshot to use for this query.

      • 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

      • Read

        public Read()

    • Method Detail

      • 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>>

      • withResultMapper

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