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