Apache Doris 中文技术论坛
Questions Tags Users Badges

在普通java 应用中 如何在数据不落盘的情况下使用stram loader

Asked Dec 5, 2024 Modified Jan 1, 0001
Viewed 77
2.1 storage catalog ingestion

目前处理数据用的都是spark 或者flink,如果在普通java 应用中,需要插入数据到doris,如何在但是doris 官方不建议使用 jdbc insert ,那么如果在数据部落盘的情况下,直接从内存中写入到 doris(不先生成 csv 或txt)

edited Jan 1, 0001
forest35
asked Dec 5, 2024
1 Answers

可以参考这个案例来写哈:
https://github.com/apache/doris/blob/master/samples/stream_load/java/DorisStreamLoad.java

edited Jan 1, 1970
黄海军@SelectDB5218
answered Dec 5, 2024
Related Questions
Doris 2.1.4版本,be节点崩溃重启后集群恢复很慢问题
1 answers
Doris2.1.4 be节点宕机,jemalloc相关问题
使用UNIQUE KEY建表时候,用日期建分区,日期字段不是跟在id后面,一定要列出日期字段前面所有字段才能建分区吗
1 answers
Doris CBO 导致的BE节点内存规律性波动问题
1 answers
ROUTINE LOAD导入kafka数据,当kafka是cdc数据,JSON格式,带删除标识的:op:d
1 answers
jdbc catalog 地址修改有残留
1 answers

Terms of service Privacy policy

Powered by Answer - the open-source software that powers Q&A communities.
Made with love © 2026 Apache Doris 中文技术论坛.