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

Class SchemaUtil

java.lang.Object

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

public class SchemaUtil
extends Object

Provides utility functions for working with Beam Schema types.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	SchemaUtil.BeamRowMapper	A JdbcIO.RowMapper implementation that converts JDBC results into Beam Row objects.

Constructor Summary

Constructors

Constructor	Description
SchemaUtil()

Method Summary

Modifier and Type	Method	Description
static boolean	compareSchemaField(Schema.Field a, Schema.Field b)	compares two fields.
static Schema	toBeamSchema(ResultSetMetaData md)	Infers the Beam Schema from ResultSetMetaData.

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaUtil

public SchemaUtil()

Method Details

toBeamSchema

public static Schema toBeamSchema(ResultSetMetaData md)
                           throws SQLException

Infers the Beam Schema from ResultSetMetaData.

Throws:

SQLException

compareSchemaField

public static boolean compareSchemaField(Schema.Field a,
 Schema.Field b)

compares two fields. Does not compare nullability of field types.

Parameters:

a - field 1

b - field 2

Returns:

TRUE if fields are equal. Otherwise FALSE