public class SchemaUtil
extends java.lang.Object
Schema types.| 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