public class SchemaUtil
extends java.lang.Object
Schema types.| Modifier and Type | Class and Description | 
|---|---|
| static class  | SchemaUtil.BeamRowMapperA  JdbcIO.RowMapperimplementation that converts JDBC
 results into BeamRowobjects. | 
| Constructor and Description | 
|---|
| SchemaUtil() | 
| Modifier and Type | Method and Description | 
|---|---|
| static boolean | compareSchemaField(Schema.Field a,
                  Schema.Field b)compares two fields. | 
| static Schema | toBeamSchema(java.sql.ResultSetMetaData md)Infers the Beam  SchemafromResultSetMetaData. | 
public static Schema toBeamSchema(java.sql.ResultSetMetaData md) throws java.sql.SQLException
Schema from ResultSetMetaData.java.sql.SQLExceptionpublic static boolean compareSchemaField(Schema.Field a, Schema.Field b)
a - field 1b - field 2