南七星之家 发表于 2025-1-19 13:24:38

doris: Flink导入数据

使用 Flink Doris Connector 可以及时的将 Flink 产生的数据（如：Flink 读取 Kafka，MySQL 中的数据）导入到 Doris 中。
使用限定​

必要依赖用户部署的 Flink 集群。
使用 Flink 导入数据​

使用 Flink 导入数据，具体步骤可以参考 Flink-Doris-Connector。在以下步骤中，演示怎样通过 Flink 快速导入数据。
第 1 步：创建表​

CREATE TABLE `students` (
`id` INT NULL,
`name` VARCHAR(256) NULL,
`age` INT NULL
) ENGINE=OLAP
UNIQUE KEY(`id`)      
COMMENT 'OLAP'
DISTRIBUTED BY HASH(`id`) BUCKETS 1
PROPERTIES (                                                         
"replication_allocation" = "tag.location.default: 1"
);

第 2 步：使用 Flink 导入数据​

运行 bin/sql-client.sh 打开 FlinkSQL 的控制台
CREATE TABLE student_sink (
    id INT,
    name STRING,
    age INT
    )
    WITH (
      'connector' = 'doris',
      'fenodes' = '10.16.10.6:28737',
      'table.identifier' = 'test.students',
      'username' = 'root',
      'password' = '',
      'sink.label-prefix' = 'doris_label'
);

INSERT INTO student_sink values(1,'zhangsan',123)

第 3 步：检查导入数据​

mysql> select * from test.students;                                                                                                                        
+------+----------+------+      
| id   | name   | age|   
+------+----------+------+                                                                                                                           
|1   | zhangsan |123 |   
+------+----------+------+   
1 rows in set (0.05 sec)
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页: [1]
查看完整版本: doris: Flink导入数据