Interface Summary Interface Description RegistryJpaIO.QueryComposerFactory<T> RegistryPipelineComponentComponent that provides everything needed on a Pipeline worker. RegistryPipelineComponent.Builder RegistryPipelineOptionsDefines Nomulus-specific pipeline options, e.g.
Class Summary Class Description JpaDemoPipelineToy pipeline that demonstrates how to use
JpaTransactionManagerin BEAM pipelines.
transformsfor a BEAM pipeline that interacts with a single database through a
transformthat transactionally executes a JPA
CriteriaQueryand adds the results to the BEAM pipeline.
transformthat writes a PCollection of entities to the SQL database using the
RegistryPipelineWorkerInitializerSets up Nomulus environment and initializes JPA on each pipeline worker.