@Experimental(value=SOURCE_SINK)
See: Description
| 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.ReadWithPartitions<T,PartitionColumnT> | |
| JdbcIO.RetryConfiguration |
Builder used to help with retry configuration for
JdbcIO. |
| 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. |
| JdbcIO.WriteWithResults<T,V extends JdbcWriteResult> |
A
PTransform to write to a JDBC datasource. |
| JdbcSchemaIOProvider |
An implementation of
SchemaIOProvider for reading and writing JSON payloads with JdbcIO. |
| JdbcWriteResult |
The result of writing a row to JDBC datasource.
|