-
ETL-12-apache SeaTunnel Transform v2 Transform Common Options
Transform Common Options
Transform 插件的通用参数
名称
类型
必需
默认值
result_table_name
字符串
否
-
source_table_name
...
2024-01-05 13:01:55 |
ETL
-
ETL-12-apache SeaTunnel Transform QA
1. 为什么我需要安装类似Spark或Flink的计算引擎?
SeaTunnel目前使用诸如Spark和Flink的计算引擎来完成资源调度和节点通信,这样我们可以专注于数据同步的易用性和高性能组件的开发。但这只是暂时的。
2. 我有一个问题,而且我自己解决不了。
在使用SeaTunnel时,我遇到了一个问题,而我自己解决不了。
我该怎么办?首先,在问题列表或邮件列表中搜索,看看是否有...
2024-01-05 13:01:55 |
ETL
-
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