| Interface | Description |
|---|---|
| JdbcIO.PreparedStatementSetter<T> |
An interface used by the JdbcIO Write to set the parameters of the
PreparedStatement
used to setParameters into the database. |
| JdbcIO.RetryStrategy |
An interface used to control if we retry the statements when a
SQLException occurs. |
| JdbcIO.RowMapper<T> |
An interface used by
JdbcIO.Read for converting each row of the ResultSet into
an element of the resulting PCollection. |
| JdbcIO.StatementPreparator |
An interface used by the JdbcIO Write to set the parameters of the
PreparedStatement
used to setParameters into the database. |
| Class | Description |
|---|---|
| JdbcIO |
IO to read and write data on JDBC.
|
| JdbcIO.DataSourceConfiguration |
A POJO describing a
DataSource, either providing directly a DataSource or all
properties allowing to create a DataSource. |
| JdbcIO.DataSourceProviderFromDataSourceConfiguration |
Wraps a
JdbcIO.DataSourceConfiguration to provide a DataSource. |
| JdbcIO.DefaultRetryStrategy |
This is the default
Predicate we use to detect DeadLock. |
| JdbcIO.PoolableDataSourceProvider |
Wraps a
JdbcIO.DataSourceConfiguration to provide a PoolingDataSource. |
| JdbcIO.Read<T> |
Implementation of
JdbcIO.read(). |
| JdbcIO.ReadAll<ParameterT,OutputT> |
Implementation of
JdbcIO.readAll(). |
| JdbcIO.ReadRows |
Implementation of
JdbcIO.readRows(). |
| JdbcIO.Write<T> |
This class is used as the default return value of
JdbcIO.write(). |
| JdbcIO.WriteVoid<T> |
A
PTransform to write to a JDBC datasource. |
| JdbcUtil |
Provides utility functions for working with
JdbcIO. |
| LogicalTypes |
Beam
Schema.LogicalType implementations of JDBC types. |
| LogicalTypes.FixedLengthBytes |
Fixed length byte types such as BINARY.
|
| LogicalTypes.FixedLengthString |
Fixed length string types such as CHAR.
|
| LogicalTypes.FixedPrecisionNumeric |
Fixed precision numeric types such as NUMERIC.
|
| LogicalTypes.JdbcLogicalType<T> |
Base class for JDBC logical types.
|
| LogicalTypes.VariableLengthBytes |
Variable length bytes types such as VARBINARY and LONGVARBINARY.
|
| LogicalTypes.VariableLengthString |
Variable length string types such as VARCHAR and LONGVARCHAR.
|
| Exception | Description |
|---|---|
| BeamSchemaInferenceException |
Exception to signal that inferring the Beam schema from the JDBC source failed.
|