Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
catalogs:
	- name: ...
	  type: jdbc
	  username: xxx
	  password: yyy
	  base_-url: jdbc:... 
      default-database: ... # optional, dbms specific, will be access id in postgres

Versions

We reply on driver itself for backward compatibility. Users can also build jars with their own versions.

...

Flink Type

Postgres Type

smallint

smallint

int

integer

bigint

bigint

float

real

double

double precision

decimal(p,s)

numeric(p,s)

boolean

boolean

timestamp

timestamp without timezone

timestamp with local timezonetimestamp with timezo timezone (depending on pg server timezone)

date

date

time

time without timezone

time with timezonetime with

timezone

intervalinterval

string

text

varchar(n)

character varying

char

char, character

binary/varbinary/bytes

bytea

array

[] (array of all the above primitive types)

...