public class BeamRecordSqlType extends BeamRecordType
BeamRecord
with SQL types.
Limited SQL types are supported now, visit data types for more details.
Modifier and Type | Field and Description |
---|---|
java.util.List<java.lang.Integer> |
fieldTypes |
Modifier | Constructor and Description |
---|---|
protected |
BeamRecordSqlType(java.util.List<java.lang.String> fieldsName,
java.util.List<Coder> fieldsCoder) |
Modifier and Type | Method and Description |
---|---|
static BeamRecordSqlType |
create(java.util.List<java.lang.String> fieldNames,
java.util.List<java.lang.Integer> fieldTypes) |
boolean |
equals(java.lang.Object obj) |
java.lang.Integer |
getFieldTypeByIndex(int index) |
java.util.List<java.lang.Integer> |
getFieldTypes() |
int |
hashCode() |
java.lang.String |
toString() |
void |
validateValueType(int index,
java.lang.Object fieldValue)
Validate input fieldValue for a field.
|
findIndexOfField, getFieldCount, getFieldNameByIndex, getFieldNames, getRecordCoder
protected BeamRecordSqlType(java.util.List<java.lang.String> fieldsName, java.util.List<Coder> fieldsCoder)
public static BeamRecordSqlType create(java.util.List<java.lang.String> fieldNames, java.util.List<java.lang.Integer> fieldTypes)
public void validateValueType(int index, java.lang.Object fieldValue) throws java.lang.IllegalArgumentException
BeamRecordType
validateValueType
in class BeamRecordType
java.lang.IllegalArgumentException
- throw exception when the validation fails.public java.util.List<java.lang.Integer> getFieldTypes()
public java.lang.Integer getFieldTypeByIndex(int index)
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class BeamRecordType