flink-connector-opensearch
Stream indexer
Connects Flink data streams to OpenSearch for indexing and querying
Apache flink
23 stars
32 watching
24 forks
Language: Java
last commit: 22 days ago connectordatastreamflinkopensearchsqltable
Related projects:
Repository | Description | Stars |
---|---|---|
apache/flink-connector-aws | Provides connectivity between Apache Flink and Amazon Web Services (AWS) for real-time data processing | 58 |
apache/flink-connector-pulsar | A connector for streaming data from a distributed messaging system to Apache Flink | 50 |
apache/flink-connector-jdbc | A Java-based connector for connecting Apache Flink to relational databases via JDBC. | 121 |
apache/flink-connector-hbase | A connector for integrating HBase with the Apache Flink stream processing framework | 29 |
apache/flink-connector-gcp-pubsub | A Java-based connector for integrating Google Cloud PubSub with Apache Flink's data processing framework | 11 |
apache/flink-connector-rabbitmq | A Flink connector for RabbitMQ message broker | 19 |
apache/flink-connector-prometheus | A Java-based connector for integrating Prometheus data into Apache Flink stream processing applications | 8 |
snowflakedb/snowflake-kafka-connector | A plugin that enables data ingestion from Kafka topics to Snowflake tables | 139 |
apache/rocketmq-connect | A tool for streaming data between Apache RocketMQ and other systems | 122 |
flink-china/flink-forward-sf-2017 | A collection of slides and videos from the Apache Flink conference in San Francisco 2017 | 17 |
apache/hbase-connectors | Connects Apache HBase with other systems like Kafka and Spark for data processing and integration. | 236 |
apache/rocketmq-flink | Provides integration for RocketMQ with Apache Flink, enabling data streaming and messaging using the RocketMQ source and sink. | 142 |
openscoring/openscoring | A REST web service for real-time model scoring with high performance and extensibility | 580 |
mysql/mysql-connector-j | Provides a Java driver for connecting to MySQL databases | 915 |
arkena00/ndb | Provides a flexible and generic interface to connect to various databases using C++ queries. | 30 |