Package google.registry.beam.common
package google.registry.beam.common
-
ClassDescriptionContains IO
transformsfor a BEAM pipeline that interacts with a single database through aJpaTransactionManager.RegistryJpaIO.Read<R,T> Atransformthat transactionally executes a JPACriteriaQueryand adds the results to the BEAM pipeline.Atransformthat writes a PCollection of entities to the SQL database using theJpaTransactionManager.Component that provides everything needed on a Pipeline worker.Defines Nomulus-specific pipeline options, e.g.Sets up Nomulus environment and initializes JPA on each pipeline worker.Interface for query instances used byRegistryJpaIO.Read.