public class SchemaUtil
extends java.lang.Object
Schema types.| Modifier and Type | Class and Description | 
|---|---|
static class  | 
SchemaUtil.BeamRowMapper
A  
JdbcIO.RowMapper implementation that converts JDBC
 results into Beam Row objects. | 
| 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  
Schema from ResultSetMetaData. | 
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