com.zto.fire.flink.bean

类 FlinkTableSchema

java.lang.Object

com.zto.fire.flink.bean.FlinkTableSchema

所有已实现的接口:

Serializable

public class FlinkTableSchema
extends Object
implements Serializable

flink表模式，支持序列化

作者:

ChengLong 2020年1月16日 16:56:23

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
FlinkTableSchema(org.apache.flink.table.api.TableSchema schema)

方法概要

限定符和类型	方法和说明
boolean	equals(Object o)
int	getFieldCount() Returns the number of fields.
Optional<org.apache.flink.table.types.DataType>	getFieldDataType(int fieldIndex) Returns the specified data type for the given field index.
Optional<org.apache.flink.table.types.DataType>	getFieldDataType(String fieldName) Returns the specified data type for the given field name.
org.apache.flink.table.types.DataType[]	getFieldDataTypes() Returns all field data types as an array.
Optional<String>	getFieldName(int fieldIndex) Returns the specified name for the given field index.
String[]	getFieldNames() Returns all field names as an array.
Optional<org.apache.flink.api.common.typeinfo.TypeInformation<?>>	getFieldType(int fieldIndex) This method will be removed in future versions as it uses the old type system.
Optional<org.apache.flink.api.common.typeinfo.TypeInformation<?>>	getFieldType(String fieldName) This method will be removed in future versions as it uses the old type system.
org.apache.flink.api.common.typeinfo.TypeInformation<?>[]	getFieldTypes() This method will be removed in future versions as it uses the old type system.
int	hashCode()
String	toString()

从类继承的方法 java.lang.Object

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

构造器详细资料

FlinkTableSchema

public FlinkTableSchema(org.apache.flink.table.api.TableSchema schema)

方法详细资料

getFieldDataTypes

public org.apache.flink.table.types.DataType[] getFieldDataTypes()

Returns all field data types as an array.

getFieldTypes

public org.apache.flink.api.common.typeinfo.TypeInformation<?>[] getFieldTypes()

This method will be removed in future versions as it uses the old type system. It is recommended to use getFieldDataTypes() instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.

getFieldDataType

public Optional<org.apache.flink.table.types.DataType> getFieldDataType(int fieldIndex)

Returns the specified data type for the given field index.

参数:

fieldIndex - the index of the field

getFieldType

public Optional<org.apache.flink.api.common.typeinfo.TypeInformation<?>> getFieldType(int fieldIndex)

This method will be removed in future versions as it uses the old type system. It is recommended to use getFieldDataType(int) instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.

getFieldDataType

public Optional<org.apache.flink.table.types.DataType> getFieldDataType(String fieldName)

Returns the specified data type for the given field name.

参数:

fieldName - the name of the field

getFieldType

public Optional<org.apache.flink.api.common.typeinfo.TypeInformation<?>> getFieldType(String fieldName)

This method will be removed in future versions as it uses the old type system. It is recommended to use getFieldDataType(String) instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.

getFieldCount

public int getFieldCount()

Returns the number of fields.

getFieldNames

public String[] getFieldNames()

Returns all field names as an array.

getFieldName

public Optional<String> getFieldName(int fieldIndex)

Returns the specified name for the given field index.

参数:

fieldIndex - the index of the field

toString

public String toString()

覆盖:

toString 在类中 Object

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object