A C D E F G H L M O P Q S T

A

acceptsURL(String) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.PostgresFactory

C

compatibleConverterName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialectConverter

compatibleDialectName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialect

compatibleDriverName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialect

CompatiblePostgresDialect - org.apache.flink.connector.jdbc.postgres.database.dialect中的类

JDBC dialect for PostgreSQL compatible databases.

CompatiblePostgresDialect() - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialect

CompatiblePostgresDialectConverter - org.apache.flink.connector.jdbc.postgres.database.dialect中的类

JDBC converter for PostgreSQL compatible databases.

CompatiblePostgresDialectConverter(RowType) - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialectConverter

compatibleRowConverter(RowType) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialect

converterName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialectConverter

converterName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialectConverter

createCatalog(ClassLoader, String, String, String, String, String) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.PostgresFactory

createDialect() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.PostgresFactory

createInternalConverter(LogicalType) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialectConverter

createNullableExternalConverter(LogicalType) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialectConverter

D

decimalPrecisionRange() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

DEFAULT_DATABASE - 类 中的静态变量org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

defaultDriverName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialect

defaultDriverName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

dialectName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialect

dialectName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

dialectTypeMapper - 类 中的变量org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

E

equals(Object) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

F

fromFlinkTableName(String) - 类 中的静态方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

fromJDBCType(ObjectPath, ResultSetMetaData, int) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

Converts Postgres type to Flink DataType.

G

getBuiltinSchemas() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

getDBType() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTypeMapper

getDefaultSchemaName() - 类 中的静态方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

getFullPath() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

getLimitClause(long) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

getMapping(String, int, int) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTypeMapper

getPgSchemaName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

getPgTableName() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

getPureTables(Connection, List<String>) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

getRowConverter(RowType) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.CompatiblePostgresDialect

getRowConverter(RowType) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

getSchemaName(ObjectPath) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

getSchemaTableName(ObjectPath) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

getTableName(ObjectPath) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

getUpsertStatement(String, String[], String[]) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

Postgres upsert query.

H

hashCode() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

L

listDatabases() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

listTables(String) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

M

mapping(ObjectPath, ResultSetMetaData, int) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTypeMapper

O

org.apache.flink.connector.jdbc.postgres.database - 程序包 org.apache.flink.connector.jdbc.postgres.database

org.apache.flink.connector.jdbc.postgres.database.catalog - 程序包 org.apache.flink.connector.jdbc.postgres.database.catalog

org.apache.flink.connector.jdbc.postgres.database.dialect - 程序包 org.apache.flink.connector.jdbc.postgres.database.dialect

P

PG_BIGSERIAL - 类 中的静态变量org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTypeMapper

PG_SERIAL - 类 中的静态变量org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTypeMapper

PostgresCatalog - org.apache.flink.connector.jdbc.postgres.database.catalog中的类

Catalog for PostgreSQL.

PostgresCatalog(ClassLoader, String, String, String, String, String) - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

PostgresCatalog(ClassLoader, String, String, String, Properties) - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

PostgresCatalog(ClassLoader, String, String, String, String, String, JdbcCatalogTypeMapper) - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

已过时。

PostgresCatalog(ClassLoader, String, String, String, JdbcCatalogTypeMapper, Properties) - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

PostgresDialect - org.apache.flink.connector.jdbc.postgres.database.dialect中的类

JDBC dialect for PostgreSQL.

PostgresDialect() - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

PostgresDialectConverter - org.apache.flink.connector.jdbc.postgres.database.dialect中的类

Runtime converter that responsible to convert between JDBC object and Flink internal object for PostgreSQL.

PostgresDialectConverter(RowType) - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialectConverter

PostgresFactory - org.apache.flink.connector.jdbc.postgres.database中的类

Factory for PostgresDialect.

PostgresFactory() - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.PostgresFactory

PostgresTablePath - org.apache.flink.connector.jdbc.postgres.database.catalog中的类

Table path of PostgresSQL in Flink.

PostgresTablePath(String, String) - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

PostgresTypeMapper - org.apache.flink.connector.jdbc.postgres.database.catalog中的类

PostgresTypeMapper util class.

PostgresTypeMapper() - 类 的构造器org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTypeMapper

Q

quoteIdentifier(String) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

S

supportedTypes() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

T

tableExists(ObjectPath) - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

timestampPrecisionRange() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.dialect.PostgresDialect

toFlinkTableName(String, String) - 类 中的静态方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

toString() - 类 中的方法org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresTablePath

A C D E F G H L M O P Q S T