Deeservent commented on issue #1198: URL: https://github.com/apache/incubator-paimon/issues/1198#issuecomment-1557065061
@zhuangchong created by Flink SQL client, Here is the complete ddl! create table paimon.ods.zt_tc_order_paimon( id bigint comment '', seller_id bigint comment '', buyer_id bigint comment '', order_no string comment '', parent_order_no string comment '', order_no_out string comment '', trade_type int comment '', trade_status int comment '', channel string comment '', source int comment '', client string comment '', payment_time timestamp comment '', amount decimal(18,2) comment '', orgin_amount decimal(18,2) comment '', delivery_fee decimal(18,2) comment '', actual_amount decimal(18,2) comment '', discount_price decimal(18,2) comment '', device_id string comment '', is_reverse int comment '', is_normal int comment '', operator_id bigint comment '', expect_receive_type int comment '', expect_receive_time timestamp comment '', ext_data string comment '', create_time timestamp comment '', update_time timestamp comment '', creator string comment '', modifier string comment '', app_id string comment '', is_deleted int comment '', version_no int comment '', tenant_id string comment '', merchant_id bigint comment '', channel_code string comment '', shop_code string comment '', order_receive_time timestamp comment '', order_logistics_time timestamp comment '', is_parent int comment '', cancel_reason_desc string comment '', cancel_type int comment '', cancel_operate_id bigint comment '', cancel_time timestamp comment '', user_type string comment '', can_reverse int comment '', delivery_type_code string comment '', cancel_reason_id int comment '', shop_type int comment '', is_pre_sale int comment '', ext_param string comment '', is_show int comment '', expect_delivery_time timestamp comment '', dt STRING, PRIMARY KEY (dt,id) NOT ENFORCED ) PARTITIONED BY (dt) with ( 'bucket'='3', 'bucket-key'='id', 'file.format'='parquet', 'merge-engine'='partial-update', 'changelog-producer' = 'full-compaction', --指定 changelog producer 为 full-compaction 'changelog-producer.compaction-interval' = '1 min', --指定 campaction 的间隔为40秒 'snapshot.time-retained' = '3h', 'partial-update.ignore-delete'='true', 'full-compaction.delta-commits' ='10' ); -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
