Flink-connector-debezium
基于Red Hat开源的Debezium组件，和Flink结合，实现在Flink上直接监听各种数据库的Change Log，并且能够利用Flink的特性，输出到不同的位置上，以实现数据总线和实时数仓的构建。此项目主要应用于数据中台或数据平台中数据总线的基础底座。
目前Debezium支持了MySQL、MongoDB、PostgreSQL、Oracle、SQL Server、Db2和Cassandra。理论上此连接器也支援以上所有数据库。
Getting Started
mvn clean package -DskipTests
example
参考DebeziumSourceITCase
2021-09-17 01:50:43
20KB
1
DataStax for Developers
Learn and build with your favorite language and a friendly GUI.
2021-09-10 16:36:41
83.15MB
1
内容是Thrift访问cassandra数据库，主程序中有多种写入的方式，其中批量写入cassandra数据库的批量写入方法最快能达到1秒1W条数据的写入速度。
2021-07-27 14:01:42
702KB
1
该文件时python 程序对接Cassandra数据库的驱动包，本人的使用环境时将python写的生产数据的程序生产数据，对接Cassandra数据库，对Cassandra数据库测压专用。
2021-07-10 16:24:32
215KB
1
编程方式设置Cassandra，主要包含以下5个包，W3C认证
slf4j-api-1.7.5.jar
cassandra-driver-core-2.0.2.jar
guava-16.0.1.jar
metrics-core-3.0.2.jar
netty-3.9.0.Final.jar
2021-07-09 11:17:45
3.47MB
1
独家新闻
UBC SCOOPS（科学合作学生协会）基于Node.js的内容API。 使用Restify构建主要的HTTP端点，使用Cassandra构建数据的持久性，使用Redis构建令牌的快速存储。
功能概要
服务器提供公共端点用于用户注册以及读取文章和事件数据。 这用于面向公众的Web客户端。 写入（POST和PATCH）需要一个承载令牌，可以在/ token端点使用客户端密钥/秘密和用户电子邮件/密码来请求承载令牌。 表单和响应资源将在将来包括在内。
运行服务器
依赖关系-安装node.js并运行npm install
设置Cassandra-持久性需要本地或远程的Cassandra入口点。 必须在config.json中指定Cassandra主机，端口，凭据和密钥空间。
创建Cassandra表-在根项目文件夹中，运行npm run createtables在配置的数据库和键空
2021-04-30 17:03:06
31KB
1