org.apache.flink.connector.jdbc.postgres.database.catalog

类 PostgresTypeMapper

java.lang.Object

org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTypeMapper

所有已实现的接口:

org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper

@Internal
public class PostgresTypeMapper
extends Object
implements org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper

PostgresTypeMapper util class.

字段概要

字段

限定符和类型	字段和说明
protected static String	PG_BIGSERIAL
protected static String	PG_SERIAL

构造器概要

构造器

构造器和说明
PostgresTypeMapper()

方法概要

限定符和类型	方法和说明
protected String	getDBType()
protected org.apache.flink.table.types.DataType	getMapping(String pgType, int precision, int scale)
org.apache.flink.table.types.DataType	mapping(org.apache.flink.table.catalog.ObjectPath tablePath, ResultSetMetaData metadata, int colIndex)

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

PG_SERIAL

protected static final String PG_SERIAL

另请参阅:

常量字段值

PG_BIGSERIAL

protected static final String PG_BIGSERIAL

另请参阅:

常量字段值

构造器详细资料

PostgresTypeMapper

public PostgresTypeMapper()

方法详细资料

mapping

public org.apache.flink.table.types.DataType mapping(org.apache.flink.table.catalog.ObjectPath tablePath,
                                                     ResultSetMetaData metadata,
                                                     int colIndex)
                                              throws SQLException

指定者:

mapping 在接口中 org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper

抛出:

SQLException

getMapping

protected org.apache.flink.table.types.DataType getMapping(String pgType,
                                                           int precision,
                                                           int scale)

getDBType

protected String getDBType()