mysql=>kafka=>elasticsearch=>doris on es

Former-commit-id: 98fcd5e86d4c97fe9e1ecbaa8672be1f2b42d852
Former-commit-id: ae9a56856aed5ea532aa45ad3d4b5318f5338cb0
1.0
wanggang 4 years ago
parent 0c9130ded4
commit aaebe8f810

@ -102,6 +102,22 @@ AGGREGATE KEY(Id,UserName)
DISTRIBUTED BY HASH(Id) BUCKETS 10
PROPERTIES("replication_num" = "1");
## doris 創建 Elasticsearch 外部表:
參考http://doc.dorisdb.com/2146013#6531__85
CREATE EXTERNAL TABLE ES_User01
(
Id CHAR(36),
UserName VARCHAR(2048)
)
ENGINE=ELASTICSEARCH
PROPERTIES (
"hosts" = "http://172.172.0.30:9200",
"index" = "mysql.example.user",
"type" = "_doc"
);
## kafka 导入 doris未完成
查看导入任务:

Loading…
Cancel
Save