实时计算Flink版：创建交互式分析Hologres结果表

create table Hologres_sink(
  name varchar,
  age BIGINT,
  birthday BIGINT
) with (
  type='hologres',
  dbname='<yourDbname>',
  tablename='<yourTablename>',
  username='<yourUsername>',
  password='<yourPassword>',
  endpoint='<yourEndpoint>',
  field_delimiter='|' --该参数可选。
);

• Exactly-once（仅一次）：即使在发生各种故障的情况下，系统只处理一次数据或事件。
• At-least-once（至少一次）：如果在系统完全处理之前丢失了数据或事件，则从源头重新传输，因此可以多次处理数据或事件。如果第一次重试成功，则不必进行后续重试。

• 如果Hologres物理表未设置主键，则Hologres Sink使用At-least-once语义。
• 如果Hologres物理表已设置主键，则Hologres Sink通过主键确保Exactly-once语义。当同主键数据出现多次时，您需要设置mutateType参数确定更新结果表的方式，mutateType取值如下：
  • insertorignore（默认值）：保留首次出现的数据，忽略后续所有数据。
  • insertorreplace：使用后续出现的数据整行替换已有数据。
  • insertorupdate：使用后续出现的数据选择性替换已有数据。
  说明

  • 当mutateType设置为insertorupdate或insertorreplace时，系统根据主键更新数据。
  • Blink定义的结果表中的数据列数不一定要和Hologres物理表的列数一致，您需要保证缺失的列没有非空约束，即列值可以为Null，否则会报错。
• 默认情况下，Hologres Sink只能向一张表导入数据。如果导入数据至分区表的父表，即使导入成功，也会查询数据失败。您可以设置参数partitionRouter为true，开启自动将数据路由到对应分区表的功能。注意事项如下：
  • tablename参数需要填写为父表的表名。
  • Blink Connector不会自动创建分区表，因此，需要您提前手动创建需要导入数据的分区表，否则会导入失败。