GitHub topics: flink-connector
devlive-community/dameng-connector
Dameng Connector 是一个专门为达梦数据库(DM Database)设计的变更数据捕获(CDC)解决方案。该项目通过扩展 Debezium 和 Flink CDC,实现了对达梦数据库的实时数据变更监控、捕获和处理能力,为数据集成、数据同步、实时分析等场景提供强大支持。
Language: Java - Size: 313 KB - Last synced at: about 2 months ago - Pushed at: 2 months ago - Stars: 14 - Forks: 9

itinycheng/flink-connector-clickhouse
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Language: Java - Size: 424 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 386 - Forks: 164

jeff-zou/flink-connector-redis
Asynchronous flink connector based on the Lettuce, supporting sql join and sink, query caching and debugging.
Language: Java - Size: 844 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 237 - Forks: 88

streamnative/pulsar-flink 📦
Elastic data processing with Apache Pulsar and Apache Flink
Language: Java - Size: 2.16 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 279 - Forks: 120

s2-streamstore/flink-connector-s2
Flink connector for S2
Language: Java - Size: 581 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

oceanbase/flink-connector-oceanbase
Apache Flink Connectors for OceanBase.
Language: Java - Size: 500 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 21 - Forks: 8

Aiven-Open/slack-connector-for-apache-flink
Apache Flink® connector for Slack
Language: Java - Size: 204 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 5 - Forks: 6

thomas-bouvier/mastodon-flink-connector
Flink connector for the streaming Mastodon API
Language: Java - Size: 26.4 KB - Last synced at: 2 days ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

BinZoom/flinksql-connector-oss
Flink SQL connector for OSS database
Language: Java - Size: 10.7 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 6 - Forks: 5

TNG/flink-connector-email 📦
IMAP / SMTP connectors for Apache Flink®
Language: Java - Size: 270 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 13 - Forks: 5

vinted/flink-big-query-connector
Flink connector for BigQuery
Language: Java - Size: 155 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 0

instaer/flinksql-cdc-app
基于Table/SQL API的轻量级Flink CDC应用
Language: Java - Size: 116 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 1

nkonev/flink-connector-clickhouse Fork of itinycheng/flink-connector-clickhouse
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Language: Java - Size: 273 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

mongo-flink/mongo-flink
A MongoDB connector for Apache Flink prior to 1.16. For Flink 1.16+, please use the official MongoDB connector.
Language: Java - Size: 153 KB - Last synced at: over 1 year ago - Pushed at: almost 2 years ago - Stars: 49 - Forks: 20

jcaberio/sentinel-flink-connector-featurestore
Flink connector for writing data into Amazon SageMaker Feature Store
Language: Java - Size: 0 Bytes - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

coalchan/Mock-Java
A simulation data generator with Java version
Language: Java - Size: 178 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

yang69/flink-connector-redis_2.11
forked from org.apache.bahir:flink-connector-redis_2.11:1.0
Language: Java - Size: 27.3 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 6

pangliang/flink-connector-futuopend
Language: Java - Size: 24.4 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

yagagagaga/flink-connector-redis
A Flink connector for Redis.
Language: Java - Size: 76.2 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

dahai1996/flink-connector-lettuce-redis
flink connector for redis,use letturce instead of jedis
Language: Java - Size: 46.9 KB - Last synced at: over 2 years ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

phial3/flink-connector-http
flink connectors http
Language: Java - Size: 37.1 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 0

flowerfine/flink-http-connectors
flink http connectors
Language: Java - Size: 87.9 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 0

mattczyz/flink-orc
Adds ORC support to Flink Streaming File Sink
Language: Java - Size: 57.6 KB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 9 - Forks: 1
