Class RegistryJpaIO


public final class RegistryJpaIO extends Object
Contains IO transforms for a BEAM pipeline that interacts with a single database through a JpaTransactionManager.

The JpaTransactionManager is instantiated once on each pipeline worker VM (through RegistryPipelineWorkerInitializer), made available through the static method, and is shared by all threads on the VM. Configuration is through RegistryPipelineOptions.