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)