flinkcdc读取pg的数据 flink用什么类型去接受float的类型的数据呢？

在Flink CDC读取PostgreSQL的数据时，float类型的数据会被自动映射为Java的Double类型。
因此，在编写Flink SQL或者Flink DataStream API时，可以使用Double类型来接收和处理从PostgreSQL中读取的float类型数据。例如：

DataStream<Double> floatData = env.addSource(new FlinkJDBCTableSource.Builder()
  .setDrivername("org.postgresql.Driver")
  .setDBUrl("jdbc:postgresql://localhost:5432/mydatabase")
  .setUsername("myuser")
  .setPassword("mypassword")
  .setQuery("SELECT float_column FROM mytable")
  .build())
  .map(new MapFunction<Row, Double>() {
    @Override
    public Double map(Row row) throws Exception {
      return row.getFloat(0);
    }
  });

在这个例子中，从PostgreSQL中读取的float类型数据被映射为Row对象的Float类型的第0个元素，然后通过map函数将其转换为Double类型。

Flink CDC 从 PostgreSQL 数据库中读取数据时，可以使用 DOUBLE 或 FLOAT8 类型来接收浮点数类型的数据。
在 Flink SQL 中，你可以将这些类型映射到相应的 Flink 类型。具体来说，你可以使用以下类型的映射关系：

• DOUBLE 映射到 DoubleType
• FLOAT8 映射到 FloatType

例如，如果你要创建一个表来接收从 PostgreSQL 数据库中读取的浮点数数据，则可以使用以下 SQL 语句：

CREATE TABLE my_table (
    id INT,
    value DOUBLE
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:postgresql://localhost:5432/mydatabase',
    'table-name' = 'mytable'
);

在这个例子中，value 字段被定义为 DOUBLE 类型，并且它将被映射到 Flink 的 DoubleType 类型。
总之，当从 PostgreSQL 数据库中读取浮点数数据时，你可以使用 DOUBLE 或 FLOAT8 类型来接收它们，并在 Flink SQL 中将它们映射到相应的 Flink 类型。

在Flink中，如果要接收PostgreSQL的CDC数据，对于float类型的数据可以使用FLOAT类型。Flink的CDC功能可以用于读取PostgreSQL数据库的全量快照数据和变更数据，确保数据的完整性，即使发生故障，也能采用Exactly Once方式处理。

看cdc的字段类型匹配关系https://ververica.github.io/flink-cdc-connectors/master/content/connectors/postgres-cdc.html
，此回答整理自钉群“Flink CDC 社区”