个人简介

Echo Blog


江湖无名 安心练剑
  • ETL-11-apache SeaTunnel Connector v2 sink tdengine
    TDengine TDengine 汇聚连接器 描述 用于将数据写入 TDengine。在运行 SeaTunnel 任务之前,您需要先创建一个 stable。 主要特性 √ 精确一次传输 变更数据捕获(CDC) 选项 名称 类型 是否必需 默认值 url ...
    2024-01-05 13:01:55 | ETL
  • ETL-11-apache SeaTunnel Connector v2 sink neo4j
    neo4j Neo4j sink connector 描述 将数据写入 Neo4j。 neo4j-java-driver 版本为 4.4.9 选项 名称 类型 必需 默认值 uri 字符串 是 - use...
    2024-01-05 13:01:55 | ETL
  • ETL-11-apache SeaTunnel Connector v2 sink jdbc
    Kafka Kafka 汇聚连接器 支持的引擎 Spark Flink Seatunnel Zeta 主要特性 精确一次传输 sink 配置项 默认情况下,我们将使用两阶段提交(2pc)来确保消息被精确一次发送到 Kafka。 名称 类型 是否必需 默认值 描述 ...
    2024-01-05 13:01:55 | ETL
  • ETL-11-apache SeaTunnel Connector v2 sink jdbc
    JDBC 汇聚连接器 描述 通过 JDBC 写入数据。支持批处理模式和流处理模式,支持并发写入,支持精确一次传输语义(使用 XA 事务保证)。 提示 警告:为了许可合规性,您必须自行提供数据库驱动程序,并将其复制到 $SEATNUNNEL_HOME/lib/ 目录中以使其生效。 例如,如果使用 MySQL,应下载并将 mysql-connector-java-xxx.jar 复制到...
    2024-01-05 13:01:55 | ETL
  • ETL-11-apache SeaTunnel Connector v2 sink ES
    Elasticsearch 描述 将数据输出到 Elasticsearch。 主要特点 CDC 提示 支持的引擎 支持的 Elasticsearch 版本为 >= 2.x 和 <= 8.x。 选项 名称 类型 必需 默认值 hosts ...
    2024-01-05 13:01:55 | ETL
  • ETL-11-apache SeaTunnel Connector v2 sink console
    Console Console sink connector 描述 用于将数据发送到控制台。支持流模式和批处理模式。 例如,如果上游的数据是 [age: 12, name: jared],则发送到控制台的内容如下:{“name”:”jared”,”age”:17} 选项 名称 类型 必需 默认值 ...
    2024-01-05 13:01:55 | ETL
  • ETL-10-apache SeaTunnel Connector v2 source mysql
    MySQL https://seatunnel.apache.org/docs/2.3.3/connector-v2/source/Mysql JDBC MySQL 数据源连接器 支持的引擎 Spark Flink SeaTunnel Zeta 主要特点 √ 批处理 × 流处理 √ 精确一次 √ 列投影 √ 并行性 √ 支持用户定义的拆分 支持查询 SQL 并能够实现投...
    2024-01-05 13:01:55 | ETL
  • ETL-10-apache SeaTunnel Connector v2 source mysql cdc
    MySQL-CDC MySQL-CDC https://seatunnel.apache.org/docs/connector-v2/source/MySQL-CDC MySQL CDC source connector 描述 MySQL CDC 连接器允许从MySQL数据库读取快照数据和增量数据。 本文档描述了如何设置 MySQL CDC 连接器以针对 MySQL 数据...
    2024-01-05 13:01:55 | ETL