Package org.apache.beam.sdk.io.jdbc
package org.apache.beam.sdk.io.jdbc
Transforms for reading and writing from JDBC.
-
ClassDescriptionIO to read and write data on JDBC.A POJO describing a
DataSource, either providing directly aDataSourceor all properties allowing to create aDataSource.Wraps aJdbcIO.DataSourceConfigurationto provide aDataSource.This is the defaultPredicatewe use to detect DeadLock.Wraps aJdbcIO.DataSourceConfigurationto provide aPoolingDataSource.An interface used by the JdbcIO Write to set the parameters of thePreparedStatementused to setParameters into the database.JdbcIO.Read<T>Implementation ofJdbcIO.read().JdbcIO.ReadAll<ParameterT,OutputT> Implementation ofJdbcIO.readAll().Implementation ofJdbcIO.readRows().JdbcIO.ReadWithPartitions<T,PartitionColumnT> Builder used to help with retry configuration forJdbcIO.An interface used to control if we retry the statements when aSQLExceptionoccurs.An interface used byJdbcIO.Readfor converting each row of theResultSetinto an element of the resultingPCollection.An interface used by the JdbcIO Write to set the parameters of thePreparedStatementused to setParameters into the database.JdbcIO.Write<T>This class is used as the default return value ofJdbcIO.write().APTransformto write to a JDBC datasource.JdbcIO.WriteWithResults<T,V extends JdbcWriteResult> APTransformto write to a JDBC datasource.An implementation ofSchemaTransformProviderfor reading from JDBC connections usingJdbcIO.JdbcReadWithPartitionsHelper<PartitionT>A helper forJdbcIO.ReadWithPartitionsthat handles range calculations.An implementation ofSchemaIOProviderfor reading and writing JSON payloads withJdbcIO.Provides utility functions for working withJdbcIO.The result of writing a row to JDBC datasource.An implementation ofSchemaTransformProviderfor writing to a JDBC connections usingJdbcIO.Provides utility functions for working with BeamSchematypes.AJdbcIO.RowMapperimplementation that converts JDBC results into BeamRowobjects.