Package google.registry.beam.common
-
Interface Summary Interface Description RegistryPipelineComponent Component that provides everything needed on a Pipeline worker.RegistryPipelineComponent.Builder RegistryPipelineOptions Defines Nomulus-specific pipeline options, e.g.RegistryQuery<T> Interface for query instances used byRegistryJpaIO.Read
.RegistryQuery.CriteriaQuerySupplier<T> -
Class Summary Class Description RegistryJpaIO Contains IOtransforms
for a BEAM pipeline that interacts with a single database through aJpaTransactionManager
.RegistryJpaIO.Read<R,T> Atransform
that transactionally executes a JPACriteriaQuery
and adds the results to the BEAM pipeline.RegistryJpaIO.Read.Builder<R,T> RegistryJpaIO.Write<T> Atransform
that writes a PCollection of entities to the SQL database using theJpaTransactionManager
.RegistryPipelineWorkerInitializer Sets up Nomulus environment and initializes JPA on each pipeline worker.