Package google.registry.beam.common
Class RegistryJpaIO
- java.lang.Object
-
- google.registry.beam.common.RegistryJpaIO
-
public final class RegistryJpaIO extends java.lang.Object
Contains IOtransforms
for a BEAM pipeline that interacts with a single database through aJpaTransactionManager
.The
JpaTransactionManager
is instantiated once on each pipeline worker VM (throughRegistryPipelineWorkerInitializer
), made available through the static methodTransactionManagerFactory.tm()
, and is shared by all threads on the VM. Configuration is throughRegistryPipelineOptions
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
RegistryJpaIO.Read<R,T>
Atransform
that transactionally executes a JPACriteriaQuery
and adds the results to the BEAM pipeline.static class
RegistryJpaIO.Write<T>
Atransform
that writes a PCollection of entities to the SQL database using theJpaTransactionManager
.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <R> RegistryJpaIO.Read<R,R>
read(RegistryQuery.CriteriaQuerySupplier<R> query)
static <R,T>
RegistryJpaIO.Read<R,T>read(RegistryQuery.CriteriaQuerySupplier<R> query, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
static <R,T>
RegistryJpaIO.Read<R,T>read(java.lang.String sql, boolean nativeQuery, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
static <R,T>
RegistryJpaIO.Read<R,T>read(java.lang.String jpql, java.lang.Class<R> clazz, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
static <R,T>
RegistryJpaIO.Read<R,T>read(java.lang.String sql, java.util.Map<java.lang.String,java.lang.Object> parameter, boolean nativeQuery, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
Returns aRegistryJpaIO.Read
connector based on the given native orjpql
query string.static <R,T>
RegistryJpaIO.Read<R,T>read(java.lang.String jpql, java.util.Map<java.lang.String,java.lang.Object> parameter, java.lang.Class<R> clazz, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
Returns aRegistryJpaIO.Read
connector based on the givenjpql
typed query string.static <T> RegistryJpaIO.Write<T>
write()
-
-
-
Method Detail
-
read
public static <R> RegistryJpaIO.Read<R,R> read(RegistryQuery.CriteriaQuerySupplier<R> query)
-
read
public static <R,T> RegistryJpaIO.Read<R,T> read(RegistryQuery.CriteriaQuerySupplier<R> query, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
-
read
public static <R,T> RegistryJpaIO.Read<R,T> read(java.lang.String sql, boolean nativeQuery, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
-
read
public static <R,T> RegistryJpaIO.Read<R,T> read(java.lang.String sql, @Nullable java.util.Map<java.lang.String,java.lang.Object> parameter, boolean nativeQuery, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
Returns aRegistryJpaIO.Read
connector based on the given native orjpql
query string.User should take care to prevent sql-injection attacks.
-
read
public static <R,T> RegistryJpaIO.Read<R,T> read(java.lang.String jpql, java.lang.Class<R> clazz, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
-
read
public static <R,T> RegistryJpaIO.Read<R,T> read(java.lang.String jpql, @Nullable java.util.Map<java.lang.String,java.lang.Object> parameter, java.lang.Class<R> clazz, org.apache.beam.sdk.transforms.SerializableFunction<R,T> resultMapper)
Returns aRegistryJpaIO.Read
connector based on the givenjpql
typed query string.User should take care to prevent sql-injection attacks.
-
write
public static <T> RegistryJpaIO.Write<T> write()
-
-