Class RegistryJpaIO

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      static class  RegistryJpaIO.Read<R,​T>
      A transform that transactionally executes a JPA CriteriaQuery and adds the results to the BEAM pipeline.
      static class  RegistryJpaIO.Write<T>
      A transform that writes a PCollection of entities to the SQL database using the JpaTransactionManager.
    • 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 a RegistryJpaIO.Read connector based on the given native or jpql 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 a RegistryJpaIO.Read connector based on the given jpql typed query string.
      static <T> RegistryJpaIO.Write<T> write()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • 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 a RegistryJpaIO.Read connector based on the given native or jpql 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 a RegistryJpaIO.Read connector based on the given jpql typed query string.

        User should take care to prevent sql-injection attacks.