org.apache.beam.sdk.extensions.sql

Class BeamRecordSqlType

java.lang.Object

org.apache.beam.sdk.values.BeamRecordType

org.apache.beam.sdk.extensions.sql.BeamRecordSqlType

All Implemented Interfaces:

java.io.Serializable

public class BeamRecordSqlType
extends BeamRecordType

Type provider for BeamRecord with SQL types.

Limited SQL types are supported now, visit data types for more details.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BeamRecordSqlType.Builder Builder class to construct BeamRecordSqlType.

Field Summary

Fields

Modifier and Type	Field and Description
java.util.List<java.lang.Integer>	fieldTypes

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BeamRecordSqlType(java.util.List<java.lang.String> fieldsName, java.util.List<Coder> fieldsCoder)

Method Summary

Modifier and Type	Method and Description
static BeamRecordSqlType.Builder	builder()
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.

Methods inherited from class org.apache.beam.sdk.values.BeamRecordType

findIndexOfField, getFieldCount, getFieldNameByIndex, getFieldNames, getRecordCoder

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

fieldTypes

public java.util.List<java.lang.Integer> fieldTypes

Constructor Detail

BeamRecordSqlType

protected BeamRecordSqlType(java.util.List<java.lang.String> fieldsName,
                            java.util.List<Coder> fieldsCoder)

Method Detail

create

public static BeamRecordSqlType create(java.util.List<java.lang.String> fieldNames,
                                       java.util.List<java.lang.Integer> fieldTypes)

validateValueType

public void validateValueType(int index,
                              java.lang.Object fieldValue)
                       throws java.lang.IllegalArgumentException

Description copied from class: BeamRecordType

Validate input fieldValue for a field.

Overrides:

validateValueType in class BeamRecordType

Throws:

java.lang.IllegalArgumentException - throw exception when the validation fails.

getFieldTypes

public java.util.List<java.lang.Integer> getFieldTypes()

getFieldTypeByIndex

public java.lang.Integer getFieldTypeByIndex(int index)

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class BeamRecordType

builder

public static BeamRecordSqlType.Builder builder()