Package org.apache.beam.sdk.io.jdbc

Class SchemaUtil.BeamRowMapper

java.lang.Object

org.apache.beam.sdk.io.jdbc.SchemaUtil.BeamRowMapper

All Implemented Interfaces:

Serializable, JdbcIO.RowMapper<Row>

Enclosing class:

SchemaUtil

public static final class SchemaUtil.BeamRowMapper
extends Object
implements JdbcIO.RowMapper<Row>

A JdbcIO.RowMapper implementation that converts JDBC results into Beam Row objects.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
Row	mapRow(ResultSet rs)
static SchemaUtil.BeamRowMapper	of(Schema schema)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

of

public static SchemaUtil.BeamRowMapper of(Schema schema)

mapRow

public Row mapRow(ResultSet rs)
           throws Exception

Specified by:

mapRow in interface JdbcIO.RowMapper<Row>

Throws:

Exception