【详述】java 使用flink-connector-starrocks导入数据,如何导入bitmap类型
dataType类型如何指定bitmap类型
要用bitmap函数套一下https://docs.starrocks.io/zh-cn/latest/sql-reference/sql-functions/bitmap-functions/to_bitmap
你好，你的意思是类型我指定整形，但是外层使用bitmap函数套一下，是吗？
找到办法了
建表语句如下。
CREATE TABLE page_uv (
page_id INT NOT NULL COMMENT ‘页面id’,
visit_date datetime NOT NULL COMMENT ‘访问时间’,
visit_users BITMAP BITMAP_UNION NOT NULL COMMENT ‘访问用户id’
) ENGINE=OLAP
AGGREGATE KEY( page_id , visit_date )
DISTRIBUTED BY HASH( page_id ) BUCKETS 1
PROPERTIES (
“replication_num” = “1”,
“storage_format” = “DEFAULT”
);
CREATE TABLE IF NOT EXISTS page_uv (
page_id INT NOT NULL COMMENT ‘页面id’,
visit_date timestamp NOT NULL COMMENT ‘访问时间’,
visit_users int NOT NULL COMMENT ‘访问用户id’
) WITH (
‘connector’ = ‘starrocks’,
‘jdbc-url’ = ‘xxx’,
‘load-url’ = 'xxx,
‘database-name’ = ‘xxx’,
‘table-name’ = ‘page_uv’,
‘username’ = 'xxx
‘password’ = ‘xxx’,
‘sink.buffer-flush.interval-ms’ = ‘60000’,
‘sink.properties.format’=‘json’,
‘sink.properties.strip_outer_array’=‘true’,
‘sink.properties.columns’ = ‘page_id,visit_date,visit_users, visit_users=to_bitmap(visit_users)’
);
insert into page_uv values (1, now(), 13);