文件名称:spark-binlog:一个用于使用Apache Spark结构流查询Binlog的库,用于Spark SQL,DataFrames和[MLSQL](https
文件大小:86KB
文件格式:ZIP
更新时间:2024-05-21 03:34:29
Scala
Spark Binlog库 一个用于使用Spark Spark,DataFrames和通过Apache Spark结构流查询Binlog的库。 要求 该库需要Spark 2.4+(已测试)。 某些较旧版本的Spark可能也可以使用,但未得到官方支持。 连结中 您可以在程序中的以下坐标处链接到该库: Scala2.11 这是最新的稳定版本。 MySQL Binlog: groupId: tech.mlsql artifactId: mysql-binlog_2.11 version: 1.0.4 HBase WAL: groupId: tech.mlsql artifactId: hbase-wal_2.11 version: 1.0.4 局限性 mysql-binlog仅支持插入/更新/删除事件。 其他事件将忽略。 hbase-wal仅支持Put / Delete事件。 其他事件
【文件预览】:
spark-binlog-master
----hbase-wal()
--------.DS_Store(6KB)
--------pom.xml.versionsBackup(6KB)
--------src()
--------hbase-wal.iml(80B)
--------pom.xml(6KB)
----pom.xml.versionsBackup(13KB)
----mysql-binlog()
--------mysql-binlog.iml(80B)
--------pom.xml.versionsBackup(1KB)
--------src()
--------pom.xml(1KB)
----LICENSE(11KB)
----README.md(9KB)
----binlog-common()
--------.DS_Store(6KB)
--------pom.xml.versionsBackup(540B)
--------src()
--------binlog-common.iml(80B)
--------pom.xml(531B)
----pom.xml(13KB)
----.gitignore(43B)
----dev()
--------change-version-to-2.12.sh(1018B)
--------change-version-to-2.11.sh(1018B)
--------change-scala-version.sh(2KB)