mkpipe-loader-mariadb 0.5.0

MariaDB loader for mkpipe.

mkpipe-loader-mariadb

MariaDB loader plugin for MkPipe. Writes Spark DataFrames into MariaDB tables via JDBC.

Documentation

For more detailed documentation, please visit the GitHub repository.

License

This project is licensed under the Apache 2.0 License - see the LICENSE file for details.

---

Connection Configuration

connections:
  mariadb_target:
    variant: mariadb
    host: localhost
    port: 3306
    database: mydb
    user: myuser
    password: mypassword

---

Table Configuration

pipelines:
  - name: pg_to_mariadb
    source: pg_source
    destination: mariadb_target
    tables:
      - name: public.orders
        target_name: stg_orders
        replication_method: full
        batchsize: 10000

---

Write Strategy

Control how data is written to MariaDB:

      - name: public.orders
        target_name: stg_orders
        write_strategy: upsert       # append | replace | upsert | merge
        write_key: [id]              # required for upsert/merge

Strategy	MariaDB Behavior
append	Plain INSERT via JDBC (default for incremental)
replace	Drop and recreate table, then insert (default for full)
upsert	INSERT ... ON DUPLICATE KEY UPDATE via temp table
merge	Same as upsert for MariaDB

---

Write Parallelism & Throughput

      - name: public.orders
        target_name: stg_orders
        replication_method: full
        batchsize: 10000
        write_partitions: 4

• batchsize: rows per JDBC batch INSERT.
• write_partitions: reduces concurrent JDBC connections via coalesce(N).

---

All Table Parameters

Parameter	Type	Default	Description
name	string	required	Source table name
target_name	string	required	MariaDB destination table name
replication_method	full / incremental	full	Replication strategy
batchsize	int	10000	Rows per JDBC batch insert
write_partitions	int	—	Coalesce DataFrame to N partitions before writing
write_strategy	string	—	append, replace, upsert, merge
write_key	list	—	Key columns for upsert/merge (required)
dedup_columns	list	—	Columns used for mkpipe_id hash deduplication
tags	list	[]	Tags for selective pipeline execution
pass_on_error	bool	false	Skip table on error instead of failing