org.apache.beam.sdk.io.jdbc

Class SchemaUtil.BeamRowMapper

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, JdbcIO.RowMapper<Row>

Enclosing class:

SchemaUtil

public static final class SchemaUtil.BeamRowMapper
extends java.lang.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 and Description
Row	mapRow(java.sql.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 Detail

of

public static SchemaUtil.BeamRowMapper of(Schema schema)

mapRow

public Row mapRow(java.sql.ResultSet rs)
           throws java.lang.Exception

Specified by:

mapRow in interface JdbcIO.RowMapper<Row>

Throws:

java.lang.Exception