开发者社区> 问答> 正文

Temproal Tables 请教下大家,官网中对于时态表的定义的案例是基于debezium的,我

create table produce( id string, name string, price decimal(10,4) update_time timestamp(3) metadata from ‘timestamp’ virtual, primary key(id) not enforced, watermark for update_time as update_time )with( ‘connector’=‘Kafka’, ‘topic’=‘product’, ‘scan.startup.mode’=‘earliest-offset’, ‘properties.bootstrap.server’=‘localhost:9092’ ‘value.format’=‘canal-Jason’ );

主要是 metadata那块 填写timestamp 对吗?*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-01 14:19:30 836 0
1 条回答
写回答
取消 提交回答
  • 这个问题我解决了,这样定义应该是可以*来自志愿者整理的flink邮件归档

    2021-12-01 15:08:52
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Facebook Online Schema Change原理和大规模表结构变更最佳实践 立即下载
Phoenix 全局索引原理与实践 立即下载
李劲松|Flink Table Store 典型应用场景 立即下载