35 Repositories
Java flink-cdc-connector Libraries
flink-connector-redis
github: https://github.com/future94/flink-connector-redis gitee : https://gitee.com/future94/flink-connector-redis Stargazers over time 为什么写这个项目 对比其他的
Template for an Apache Flink project.
Minimal Apache Flink Project Template It contains some basic jobs for testing if everything runs smoothly. How to Use This Repository Import this repo
Connecting Java Application With a TDengine Database.
TDengine Java Connector English | 简体中文 'taos-jdbcdriver' is TDengine's official Java language connector, which allows Java developers to develop appli
GalaxyCDC is a core component of PolarDB-X which is responsible for global binary log generation, publication and subscription.
中文文档 What is ApsaraDB GalaxyCDC ? GalaxyCDC is a core component of PolarDB-X which is responsible for global binary log generation, publication and su
GalaxyGlue is an extension to MySQL Connector/J 8.0.
中文文档 What is ApsaraDB GalaxyGlue ? GalaxyGlue is an extension to MySQL Connector/J 8.0. GalaxyGlue uses asynchronous requests, session and connection
Example Project which uses spark mongo connector !
mongo-spark-connector-springboot Example Project which uses spark mongo connector to read/aggregate & convert into Spark DataSet/Java RDDs Connects to
Open data platform based on flink. Now scaleph is supporting data integration with seatunnel on flink
scaleph The Scaleph project features data integration, develop, job schedule and orchestration and trys to provide one-stop data platform for develope
Demo Repo for our CDC-based Strangler Fig Pattern Session @ VoxxedDays Romania 2021
Strangler Fig Pattern Demo Build applications Before being able to spin up the docker-compose based demo environment please make sure to successfully
A sidecar to run alongside Trino to gather metrics using the JMX connector and expose them in different formats using Apache velocity
Overview A sidecar to run alongside Trino to gather metrics using the JMX connector and expose them in different formats using Apache Velocity. Click
Online Quiz system - JDBC, JSP
Online-Quiz-System-in-Java Online Quiz system - JDBC, JSP Java Project based on JDBC, JSP, Java Servlet and Server Deployment Project Aim Develop web
🚀flink-sql-submit is a custom SQL submission client
🚀flink-sql-submit is a custom SQL submission client This is a customizable extension of the client, unlike flink's official default client.
Integrate with Hyperledger Fabric using REST and Kafka with Block and Chaincode Event emitter.
Hyperledger Fabric REST Integration Description:- This artifact provides a mechanism to invoke and query fabric chaincode using a REST-based API inter
Flink Connector for Apache Doris(incubating)
Flink Connector for Apache Doris (incubating) Flink Doris Connector More information about compilation and usage, please visit Flink Doris Connector L
Amazon AppFlow Custom JDBC Connector example
Amazon AppFlow Custom JDBC Connector example This project contains source code and supporting files that implements Amazon Custom Connector SDK and re
Flink/Spark Connectors for Apache Doris(Incubating)
Apache Doris (incubating) Connectors The repository contains connectors for Apache Doris (incubating) Flink Doris Connector More information about com
A FlinkSQL studio and real-time computing platform based on Apache Flink
Dinky 简介 实时即未来，Dinky 为 Apache Flink 而生，让 Flink SQL 纵享丝滑，并致力于实时计算平台建设。 Dinky 架构于 Apache Flink，增强 Flink 的应用与体验，探索流式数仓。即站在巨人肩膀上创新与实践，Dinky 在未来批流一体的发展趋势下潜
A Registration Form using Java Swing with database connectivity
Registration Form A Registration Form using Java Swing with database connectivity.
Flink Table Store is a unified streaming and batch store for building dynamic tables on Apache Flink
Flink Table Store is a unified streaming and batch store for building dynamic tables on Apache Flink
Flink CDC Connectors is a set of source connectors for Apache Flink
Flink CDC Connectors is a set of source connectors for Apache Flink, ingesting changes from different databases using change data capture (CDC). The Flink CDC Connectors integrates Debezium as the engine to capture data changes.
Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
Dagger Dagger or Data Aggregator is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processi
FLiP: StreamNative: Cloud-Native: Streaming Analytics Using Apache Flink SQL on Apache Pulsar
StreamingAnalyticsUsingFlinkSQL FLiP: StreamNative: Cloud-Native: Streaming Analytics Using Apache Flink SQL on Apache Pulsar Running on NVIDIA XAVIER
Table-Computing (Simplified as TC) is a distributed light weighted, high performance and low latency stream processing and data analysis framework. Milliseconds latency and 10+ times faster than Flink for complicated use cases.
Table-Computing Welcome to the Table-Computing GitHub. Table-Computing (Simplified as TC) is a distributed light weighted, high performance and low la
A tool based on mysql-connector to simplify the use of databases, tables & columns
Description A tool based on mysql-connector to simplify the use of databases, tables & columns. This tool automatically creates the databases & tables
DataLink is a new open source solution to bring Flink development to data center.
DataLink 简介 DataLink 是一个创新的数据中台解决方案，它基于 SpringCloud Alibaba 和 Apache Flink 实现。它使用了时下最具影响力的实时计算框架Flink，而且紧跟社区发展，试图只通过一种计算框架来解决离线与实时的问题，实现Sql语义化的批流一体，帮助
tuya-spring-boot-starter helps you efficiently create cloud development projects regarding the OpenAPI or message subscription capabilities. You can put all the focus on business logic without taking care of server-side programming nor relational databases.
English | 中文版 tuya-spring-boot-starter helps you efficiently create cloud development projects regarding the OpenAPI or message subscription capabilit
DataLink is a new open source solution to bring Flink development to data center.
DataLink 简介 DataLink 是一个创新的数据中台解决方案，它基于 SpringCloud Alibaba 和 Apache Flink 实现。它使用了时下最具影响力的实时计算框架Flink，而且紧跟社区发展，试图只通过一种计算框架来解决离线与实时的问题，实现Sql语义化的批流一体，帮助
基于Apache-bahir-kudu-connector的flink-connector-kudu，支持Flink1.11.x DynamicTableSource/Sink，支持Range分区等
基于Apache-Bahir-Kudu-Connector改造而来的满足公司内部使用的Kudu Connector，支持特性Range分区、定义Hash分桶数、支持Flink1.11.x动态数据源等，改造后已贡献部分功能给社区。
Flink Demo
flink-demo minimum code just run flink-ds-connector DataStream API usage kafka es jdbc file row string parquet avro avro custom avro flink-sql-connect
Apache Flink
Apache Flink Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities. Learn more about Flin
Web-based notebook that enables data-driven, interactive data analytics and collaborative documents with SQL, Scala and more.
Apache Zeppelin Documentation: User Guide Mailing Lists: User and Dev mailing list Continuous Integration: Contributing: Contribution Guide Issue Trac
Distributed Stream and Batch Processing
What is Jet Jet is an open-source, in-memory, distributed batch and stream processing engine. You can use it to process large volumes of real-time eve
Apache Flink
Apache Flink Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities. Learn more about Flin
MariaDB Embedded in Java JAR
What? MariaDB4j is a Java (!) "launcher" for MariaDB (the "backward compatible, drop-in replacement of the MySQL(R) Database Server", see FAQ and Wiki
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Copyright Debezium Authors. Licensed under the Apache License, Version 2.0. The Antlr grammars within the debezium-ddl-parser module are licensed unde