版本：Latest-4.1

导入数据

🗃️ 导入概览

4 个项目

8 个项目

从本地文件系统使用 Stream Load 同步导入或 Broker Load 异步导入数据到 StarRocks，支持多种文件格式。

从 HDFS 导入数据到 StarRocks，支持 Parquet、ORC 和 CSV 等格式。

2 个项目

2 个项目

通过 INSERT 语句向 StarRocks 导入数据：INSERT VALUES、INSERT INTO SELECT 和动态覆盖。

使用 SQL 事务以原子方式在 StarRocks 中提交多个 INSERT、UPDATE、DELETE 语句，支持 ACID 特性。

使用 Stream Load 事务接口实现两阶段提交，支持 Flink 和 Kafka 等系统的高并发流式导入和多表事务。

使用 Flink CDC 捕获 MySQL 变更数据，实时同步至 StarRocks 进行秒级更新。

使用 Flink CDC pipeline 捕获 PostgreSQL 变更数据，并实时同步至 StarRocks 主键表。

通过 Apache Flink connector 持续加载数据到 StarRocks，支持 DataStream、Table API 和 Python API。

为 Flink 作业启用多表事务，以便在一个处理周期内向同一数据库中的多个表写入数据。

通过 Routine Load 从 Apache Pulsar 主题持续导入 CSV 和 JSON 格式数据到 StarRocks。

在 Primary Key 表中通过 Stream Load、Broker Load 或 Routine Load 实现 INSERT、UPDATE、DELETE 操作。

在导入过程中实现数据转换：列映射、过滤条件及派生列表达式在多种导入方式中的应用。

StarRocks 及生态伙伴提供的数据导入工具概览：SMT、DataX、CloudCanal 和 Kettle connector。

严格模式控制导入过程中如何处理数据类型转换失败的行，决定是否过滤无效数据。

Broker Load 支持从 HDFS 或云存储异步批量导入数据至 StarRocks，提供作业管理功能。

How to load JSON data into StarRocks using Stream Load or Routine Load, with JSON path expressions for field mapping and nested object handling.