Delta: Replicate MySQL Tables to Delta Tables

Created on 16 Dec 2019 · 1Comment · Source: delta-io/delta

delta lake There is no such example implementation. thank you
Read mysql data in real time

spark.readStream
.format("preview-cdcFromMysql")
.option("host", )
.option("username", )
.option("password", dbutils.secrets.get(, )
.option("database", )
.option("table",

)
.load()
.writeStream
.format("preview-cdcToDelta")
.option("checkpointLocation", )
.start()

Source

liangrui1988

Most helpful comment

This is a not really a API of Delta, but rather just a connector built by a vendor that glues together Debezium and the MERGE INTO command (which is available in OSS Delta Lake).

marmbrus on 16 Dec 2019

👍3

>All comments

This is a not really a API of Delta, but rather just a connector built by a vendor that glues together Debezium and the MERGE INTO command (which is available in OSS Delta Lake).

marmbrus on 16 Dec 2019

👍3

Was this page helpful?

0 / 5 - 0 ratings