How To Use MySQL-CDC Sink Kafka SeaTunnel supports to interpret cdc record as Debezium-JSON messages publish to mq(kafka) system. This is useful in many cases to leverage this ...
TPC-DS Integration Dependencies Configurations TPC-DS Operations The TPC-DS is a decision support benchmark. It consists of a suite of business oriented ad-hoc queries and con...
Support Apache RocketMQ Version Support These Engines Key Features Description Sink Options partition.key.fields [array] Task Example Fake to Rocketmq Simple Rocketmq To Roc...
Apache Paimon (Incubating) Integration Dependencies Configurations Apache Paimon (Incubating) Operations Apache Paimon(incubating) is a streaming data lake platform that suppo...
Spark Procedures To use Iceberg in Spark, first configure Spark catalogs . Stored procedures are only available when using Iceberg SQL extensions in Spark 3. Usage Procedures c...
_.castArray(value) Since Arguments Returns Example _.clone(value) Since Arguments Returns Example _.cloneDeep(value) Since Arguments Returns Example _.cloneDeepWi...
Creating your first interoperable table Using Apache XTable™ (Incubating) to sync your source tables in different target format involves running sync on your current dataset usi...