public class SqlFieldSchema
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static SqlFieldSchema |
createArraySchema(SqlFieldSchema elementType) |
static SqlFieldSchema |
createMapSchema(SqlFieldSchema valueType) |
static SqlFieldSchema |
createPrimitiveSchema(SamzaSqlFieldType typeName)
Create a primitive fi
|
static SqlFieldSchema |
createRowFieldSchema(SqlSchema rowSchema) |
SqlFieldSchema |
getElementSchema()
Get the element schema if the field type is
SamzaSqlFieldType.ARRAY |
SamzaSqlFieldType |
getFieldType()
Get teh Type of the Samza SQL Field.
|
SqlSchema |
getRowSchema()
Get the row schema if the field type is
SamzaSqlFieldType.ROW |
SqlFieldSchema |
getValueScehma()
Get the schema of the value if the field type is
SamzaSqlFieldType.MAP |
boolean |
isPrimitiveField() |
public static SqlFieldSchema createPrimitiveSchema(SamzaSqlFieldType typeName)
typeName
- public static SqlFieldSchema createArraySchema(SqlFieldSchema elementType)
public static SqlFieldSchema createMapSchema(SqlFieldSchema valueType)
public static SqlFieldSchema createRowFieldSchema(SqlSchema rowSchema)
public boolean isPrimitiveField()
public SamzaSqlFieldType getFieldType()
public SqlFieldSchema getElementSchema()
SamzaSqlFieldType.ARRAY
public SqlFieldSchema getValueScehma()
SamzaSqlFieldType.MAP
public SqlSchema getRowSchema()
SamzaSqlFieldType.ROW