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 by RegistryJpaIO.Read.
RegistryQuery.CriteriaQuerySupplier<T>

Class Summary

Class	Description
RegistryJpaIO	Contains IO transforms for a BEAM pipeline that interacts with a single database through a JpaTransactionManager.
RegistryJpaIO.Read<R,T>	A transform that transactionally executes a JPA CriteriaQuery and adds the results to the BEAM pipeline.
RegistryJpaIO.Read.Builder<R,T>
RegistryJpaIO.Write<T>	A transform that writes a PCollection of entities to the SQL database using the JpaTransactionManager.
RegistryPipelineWorkerInitializer	Sets up Nomulus environment and initializes JPA on each pipeline worker.